com.appunite.websocket.rx

Class RxWebSockets

java.lang.Object

com.appunite.websocket.rx.RxWebSockets

public class RxWebSockets
extends java.lang.Object

This class allows to retrieve messages from websocket

Constructor Summary

Constructors

Constructor and Description
RxWebSockets(com.appunite.websocket.NewWebSocket newWebSocket, java.net.URI uri) Create instance of RxWebSockets

Method Summary

Methods

Modifier and Type	Method and Description
rx.Observable<RxEvent>	webSocketObservable() Returns observable that connected to a websocket and returns RxJsonEvent's

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxWebSockets

public RxWebSockets(@Nonnull
            com.appunite.websocket.NewWebSocket newWebSocket,
            @Nonnull
            java.net.URI uri)

Create instance of RxWebSockets

Parameters:

newWebSocket - NewWebSocket instance

uri - uri for websocket (eg. "wss://some.server/endpoint")

Method Detail

webSocketObservable

@Nonnull
public rx.Observable<RxEvent> webSocketObservable()

Returns observable that connected to a websocket and returns RxJsonEvent's

Returns:

Observable that connects to websocket