com.appunite.websocket.rx.object

Class RxObjectWebSockets

java.lang.Object

com.appunite.websocket.rx.object.RxObjectWebSockets

public class RxObjectWebSockets
extends java.lang.Object

This class allows to retrieve json messages from websocket

Constructor Summary

Constructors

Constructor and Description
RxObjectWebSockets(RxWebSockets rxWebSockets, ObjectSerializer objectSerializer) Creates RxObjectWebSockets

Method Summary

Methods

Modifier and Type	Method and Description
rx.Observable<RxObjectEvent>	webSocketObservable() Returns observable that connected to a websocket and returns RxObjectEvents

Methods inherited from class java.lang.Object

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

Constructor Detail

RxObjectWebSockets

public RxObjectWebSockets(@Nonnull
                  RxWebSockets rxWebSockets,
                  @Nonnull
                  ObjectSerializer objectSerializer)

Creates RxObjectWebSockets

Parameters:

rxWebSockets - socket that is used to connect to server

objectSerializer - that is used to parse messages

Method Detail

webSocketObservable

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

Returns observable that connected to a websocket and returns RxObjectEvents

Returns:

Observable that connects to websocket

See Also:

RxWebSockets.webSocketObservable()