com.appunite.websocket.rx

Class RxMoreObservables

java.lang.Object

com.appunite.websocket.rx.RxMoreObservables

public class RxMoreObservables
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.logging.Logger	logger

Constructor Summary

Constructors

Constructor and Description
RxMoreObservables()

Method Summary

Methods

Modifier and Type	Method and Description
static rx.Observable.Transformer<java.lang.String,java.lang.Object>	sendMessage(RxEventConn connection) Transformer that convert String message to observable that returns if message was sent
static rx.Observable.Transformer<java.lang.Object,java.lang.Object>	sendMessage(RxObjectEventConn connection) Transformer that convert Object message to observable that returns if message was sent Object is parsed via ObjectSerializer given by RxObjectWebSockets.RxObjectWebSockets(RxWebSockets, ObjectSerializer)

Methods inherited from class java.lang.Object

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

Field Detail

logger

public static final java.util.logging.Logger logger

Constructor Detail

RxMoreObservables

public RxMoreObservables()

Method Detail

sendMessage

@Nonnull
public static rx.Observable.Transformer<java.lang.String,java.lang.Object> sendMessage(@Nonnull
                                                                               RxEventConn connection)

Transformer that convert String message to observable that returns if message was sent

Parameters:

connection - connection event that is used to send message

Returns:

Observable that returns Observer.onNext(Object) with new Object() and Observer.onCompleted() or Observer.onError(Throwable)

See Also:

sendMessage(ObjectWebSocketSender, Object)

sendMessage

@Nonnull
public static rx.Observable.Transformer<java.lang.Object,java.lang.Object> sendMessage(@Nonnull
                                                                               RxObjectEventConn connection)

Transformer that convert Object message to observable that returns if message was sent Object is parsed via ObjectSerializer given by RxObjectWebSockets.RxObjectWebSockets(RxWebSockets, ObjectSerializer)

Parameters:

connection - connection event that is used to send message

Returns:

Observable that returns Observer.onNext(Object) with new Object() and Observer.onCompleted() or Observer.onError(Throwable)

See Also:

sendMessage(RxEventConn)