com.appunite.websocket.rx.json

Class RxJsonWebSockets

java.lang.Object

com.appunite.websocket.rx.json.RxJsonWebSockets

public class RxJsonWebSockets
extends java.lang.Object

This class allows to retrieve json messages from websocket

Constructor Summary

Constructors

Constructor and Description
RxJsonWebSockets(RxWebSockets rxWebSockets, com.google.gson.Gson gson, java.lang.reflect.Type typeOfT) Creates RxJsonWebSockets

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RxJsonWebSockets

public RxJsonWebSockets(@Nonnull
                RxWebSockets rxWebSockets,
                @Nonnull
                com.google.gson.Gson gson,
                @Nonnull
                java.lang.reflect.Type typeOfT)

Creates RxJsonWebSockets

Parameters:

rxWebSockets - socket that is used to connect to server

gson - that is used to parse messages RxJsonEventMessage and JsonWebSocketSender.sendObjectMessage(Object)

typeOfT - type of class that is parsed to RxJsonEventMessage

Method Detail

webSocketObservable

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

Returns observable that connected to a websocket and returns RxJsonEvents

Returns:

Observable that connects to websocket

See Also:

RxWebSockets.webSocketObservable()