SocketClient

Constructor

new(?host:String, port:Int, ?reconnect:Int, ?tryCount:Int, ?isWithLength:Bool, ?maxSize:Int)

Available on flash, neko, nodejs

Variables

read onlyonTask:Signal2<Null<BytesInput>, SocketClient>

@:value(DEFAULT_LEN_BLOCK_SIZE)writeLengthSize:UInt = DEFAULT_LEN_BLOCK_SIZE

Methods

inlineremoveTask():Void

sendBytes(b:Bytes):Void

@:value({ len : 0 })sendSetTask(out:Bytes, ?prefix:Bytes, len:UInt = 0):Signal2<BytesInput, SocketClient>

@:value({ len : 0 })inlinesendSetTaskSym(b:Bytes, len:UInt = 0):Signal2<BytesInput, SocketClient>

sendStack():Void

sendString(data:String):Void

inlinesetTask(?prefix:BytesOutput, ?len:Int64):Signal2<BytesInput, SocketClient>

inlinesetTaskb(prefix:Bytes, ?len:Int64):Signal2<BytesInput, SocketClient>

dynamicwriteLength(bo:BytesOutput, length:UInt):Void

Available on flash, neko, nodejs

Inherited Variables

Defined by SocketClientBase

read onlyhost:String

@:value(-1)read onlyid:Int = -1

@:value(false)logInputData:Bool = false

@:value(false)logOutputData:Bool = false

read onlyonClose:Signal0

read onlyonData:Signal2<BytesInput, SocketClient>

read onlyonOpen:Signal0

read onlyonString:Signal2<String, SocketClient>

@:value(false)read onlyopened:Bool = false

read onlyport:Int

@:value(0)readLengthSize:UInt = 0

read onlyserver:Null<SocketServer>

Defined by Logable

read onlyerrorActive:Bool

read onlylogActive:Bool

read onlyonError:Signal2<String, Null<PosInfos>>

read onlyonLog:Signal2<String, Null<PosInfos>>

Inherited Methods

Defined by SocketClient

Defined by SocketClientBase

@:access(pony.net.SocketServer)init(server:SocketServer, id:Int):Void

logInputDataHandler(bi:BytesInput):Void

dynamicreadLength(bi:BytesInput):UInt

reconnect():Void

inlinesend2other(data:BytesOutput):Void

inlineset_logInputData(v:Bool):Bool

tryAgain():Void

Defined by Logable

inlinebench(?name:String, f:() ‑> Void, ?p:Null<PosInfos>):Void

inlinebenchAsync(?name:String, f:() ‑> Void ‑> Void, ?p:Null<PosInfos>):Void

inlinebenchComplete(name:String, ?p:Null<PosInfos>):Void

inlinebenchStart(name:String, ?p:Null<PosInfos>):Void

inlineerror(s:String, ?p:Null<PosInfos>):Void

inlineerrorf(fn:() ‑> String, ?p:Null<PosInfos>):Void

inlinelistenError(l:ILogable, ?id:String):Void

inlinelistenErrorAndLog(l:ILogable, ?id:String):Void

inlinelistenLog(l:ILogable, ?id:String):Void

inlinelog(s:String, ?p:Null<PosInfos>):Void

inlinelogf(fn:() ‑> String, ?p:Null<PosInfos>):Void

inlinestopTraceAll():Void

inlinestopTraceErrors():Void

inlinestopTraceLogs():Void

inlinetraceAll():Void

@:value({ date : false, time : true })inlinetraceErrors(time:Bool = true, date:Bool = false):Void

@:value({ date : false, time : true })inlinetraceLogs(time:Bool = true, date:Bool = false):Void