private final SocketHelper helper = new SocketHelper("127.0.0.1", 1236);
  
  
// later...
// check if connected or wifi-on
helper.connect(new SocketListener() {

           @Override
           public void onConnect(AsyncSocket socket) {
               // on successfully connected to server
           }

           @Override
           public void onError(Exception error) {
               // when an error occurred
               error.printStackTrace();
           }

           @Override
           public void onClosed(Exception error) {
               // when connection closed by server or an error occurred to forcefully close server connection
           }

           @Override
           public void onDisconnect(Exception error) {
               // when connection closed by server or self closed by calling disconnect
           }

           @Override
           public void onDataWrite(String message, Exception error) {
               // notify when data successfully sent to server
               Log.d("SocketHelper", "onDataWrite >> " + message);
               if (error != null)
                   error.printStackTrace();
           }

           @Override
           public void onDataReceived(String message, DataEmitter emitter) {
               // notify when new data received from server
               Log.d("SocketHelper", "onDataReceived >> " + message);
               if (message.startsWith("~Login")) {
                   // Request  LOGIN
               } else if (message.startsWith("~OTP")) {
                   // Request OTP
               } else if (message.startsWith("...")) {
                   // Request any?
               }
           }
       });

// delay in milis
helper.send("~LOGIN|ABCD|EFG|h|$$", delay);

final SocketServer server = SocketServer.getDefault();
        server.connectSocket("127.0.0.1", 8080, new ConnectCallback() {
            @Override
            public void onConnectCompleted(Exception ex, AsyncSocket socket) {
                if (ex != null) {
                    ex.printStackTrace();
                }
                if (socket == null) {
                    //not connected yet return
                    return;
                }
                // connected
                socket.setDataCallback(new DataCallback() {
                    @Override
                    public void onDataAvailable(DataEmitter emitter, ByteBufferReader bb) {
                        // triggered when new data available from server
                    }
                });

                socket.setWriteableCallback(new WritableCallback() {
                    @Override
                    public void onWriteable() {
                        // when something write/sent to server
                    }
                });

                socket.setClosedCallback(new CompletedCallback() {
                    @Override
                    public void onCompleted(Exception ex) {
                        // when connection closed
                    }
                });

                socket.setEndCallback(new CompletedCallback() {
                    @Override
                    public void onCompleted(Exception ex) {
                        // when connection ended
                    }
                });
            }
        });
        
        
        
        // later write to server.....
         SocketServer.getDefault().post(new Runnable() {
            @Override
            public void run() {
                // white data to server
                Util.writeAll(socketRef, dataToWrite, new CompletedCallback() {
                    @Override
                    public void onCompleted(Exception ex) {

                    }
                });
            }
        });