Install

Gradle

repositories {    jcenter()}dependencies {  implementation'com.gorgexec.rxsocketio:rxsocketio:1.0.0'}

Usage

//collection of server events to handleCollection<String>events =newArraySet<>();events.add("login");events.add("new message");events.add("logout");//socket initializationRxSocketIosocket =RxSocketIo.create("http://localhost",events);//subscribing socket statedisposable.add(socket.observeState()                .subscribe(this::onState));//subscribing socket incoming messages from serverdisposable.add(socket.observeMessages()                .subscribe(this::onIncomingMessage));socket.connect();

IO.Optionsoptions =newIO.Options();options.timeout =50000;RxSocketIosocket =RxSocketIo.create("http://localhost",events,options);

socket.emit("new message",message);

privatevoidonIncomingMessage(SocketEventsocketEvent){StringeventName =socketEvent.name();switch (eventName){case"new message":for(Objectobj:socketEvent.data()) {//do something            }break;case"logout":socket.disconnect();break;    }}

Sample App