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, java.util.List<java.lang.String> subProtocols, java.util.List<org.apache.http.Header> headers) 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 RxObjectEvent'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,
            @Nonnull
            java.util.List<java.lang.String> subProtocols,
            @Nonnull
            java.util.List<org.apache.http.Header> headers)

Create instance of RxWebSockets

Parameters:

newWebSocket - NewWebSocket instance

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

subProtocols - application-level protocols layered over the WebSocket Protocol

headers - headers sent to server

Method Detail

webSocketObservable

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

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

Returns:

Observable that connects to websocket