com.appunite.websocket.rx.json.messages

Class RxJsonEventMessage

java.lang.Object

com.appunite.websocket.rx.json.messages.RxJsonEvent

com.appunite.websocket.rx.json.messages.RxJsonEventConn

com.appunite.websocket.rx.json.messages.RxJsonEventMessage

public class RxJsonEventMessage
extends RxJsonEventConn

Event indicating that json was returned by server and was parsed If JsonParseException occur than RxJsonEventWrongMessageFormat event will be served

See Also:

RxEventStringMessage

Constructor Summary

Constructors

Constructor and Description
RxJsonEventMessage(JsonWebSocketSender sender, java.lang.Object message)

Method Summary

Methods

Modifier and Type	Method and Description
static <T> rx.Observable.Transformer<RxJsonEventMessage,T>	filterAndMap(java.lang.Class<T> clazz) Transform one observable to observable of given type filtering by a type
<T> T	message() Served parse message
java.lang.String	toString()

Methods inherited from class com.appunite.websocket.rx.json.messages.RxJsonEventConn

sender

Methods inherited from class java.lang.Object

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

Constructor Detail

RxJsonEventMessage

public RxJsonEventMessage(@Nonnull
                  JsonWebSocketSender sender,
                  @Nonnull
                  java.lang.Object message)

Method Detail

message

@Nonnull
public <T> T message()
          throws java.lang.ClassCastException

Served parse message

Type Parameters:

T - Class type of message

Returns:

a message that was returned

Throws:

java.lang.ClassCastException - when wrong try to get wrong type of message

toString

public java.lang.String toString()

Specified by:

toString in class RxJsonEvent

filterAndMap

@Nonnull
public static <T> rx.Observable.Transformer<RxJsonEventMessage,T> filterAndMap(@Nonnull
                                                                       java.lang.Class<T> clazz)

Transform one observable to observable of given type filtering by a type

Type Parameters:

T - type of message that you would like get

Parameters:

clazz - type of message that you would like get

Returns:

Observable that returns given type of message