package Ġcom . g net . lan _ manager . websocket Ċ Ċ import Ġcom . g net . lan _ manager . adapt . Socket Manager Callback Ċ import Ġcom . ko ush ik dut ta . async . Async Socket Ċ import Ġcom . ko ush ik dut ta . async . ByteBuffer List Ċ import Ġcom . ko ush ik dut ta . async . Data Emitter Ċ import Ġcom . ko ush ik dut ta . async . callback . Completed Callback Ċ import Ġcom . ko ush ik dut ta . async . callback . Data Callback Ċ import Ġcom . ko ush ik dut ta . async . http . WebSocket Ċ Ċ /** Ċ Ġ* Ċ Ġ* Ġ@ Description : ĠĠĠ Ġsocket è¿ŀæİ¥ ç±» Ċ Ġ* Ġ@ Author : ĠĠĠĠĠĠĠĠ Ġy an le i . xia Ċ Ġ* Ġ@ Create Date : ĠĠĠĠĠ 2 0 2 0 / 1 1 / 2 4 Ġ 1 7 : 1 4 Ċ Ġ*/ Ċ class ĠClient Socket ( ĊĠĠĠĠĠĠĠ Ġprivate Ġvar Ġm Socket : ĠWebSocket ?, ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġsocket Manager Callback : ĠSocket Manager Callback ? Ċ ) Ġ: ĠCompleted Callback , ĠWebSocket . String Callback , ĠData Callback Ġ{ ĊĊĠĠĠ Ġinit Ġ{ ĊĠĠĠĠĠĠĠ Ġm Socket ?. apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġstring Callback Ġ= Ġthis @ Client Socket ĊĠĠĠĠĠĠĠĠĠĠĠ Ġclosed Callback Ġ= Ġthis @ Client Socket ĊĠĠĠĠĠĠĠĠĠĠĠ Ġdata Callback Ġ= Ġthis @ Client Socket ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Completed ( ex : ĠException ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġsocket Manager Callback ?. on Disconnected ( this ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon String Available ( s : ĠString ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġsocket Manager Callback ?. on Message Received ( s ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Data Available ( emitter : ĠData Emitter ?, Ġbb : ĠByteBuffer List ?) Ġ{ ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun ĠsendMessage ( message : ĠString ?): ĠBoolean Ġ{ ĊĠĠĠĠĠĠĠ Ġif Ġ( message . isNull OrEmpty ()) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġfalse ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġreturn Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġm Socket ?. send ( message ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtrue ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġe . printStackTrace () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġfalse ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġstop Connect () Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġm Socket ?. close () ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġe . printStackTrace () ĊĠĠĠĠĠĠĠ Ġ} Ġfinally Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġm Socket Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget Async Socket (): ĠAsync Socket ? Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġm Socket ?. socket ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun ĠtoString (): ĠString Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġ"${ get Async Socket () }" ĊĠĠĠ Ġ} Ċ }