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.squareup.okhttp.OkHttpClient client, com.squareup.okhttp.Request request) 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.squareup.okhttp.OkHttpClient client,
            @Nonnull
            com.squareup.okhttp.Request request)

Create instance of RxWebSockets

Parameters:

client - OkHttpClient instance

request - request to connect to websocket

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