io.reactivex.remote

Class RemoteObservables<T>

java.lang.Object

io.reactivex.remote.RemoteObservables<T>

public final class RemoteObservables<T>
extends java.lang.Object

Helper class to create RemoteObservable and send data through it

   //Example to send RemoteObservables for send events for "Download"

   //return to client
   RemoteObservable <Integer > remoteObservable = RemoteObservables. <Integer >of("Download").newObservable();

   //notify all clients
   RemoteObservables. <Integer >of("Download")
       .onNext(50)
       .onNext(100)
       .onCompleted();

 

Method Summary

Modifier and Type	Method and Description
RemoteObservable<T>	newObservable() Creates a new RemoteObservable to return to client By default this observable will emit every data that is send using onNext(Object)
RemoteObservable<T>	newObservable(boolean ignoreDuplicates) Creates a new RemoteObservable to return to client.
static <T> RemoteObservables<T>	of(java.lang.Object type) Returns RemoteObservables tied to the given type
RemoteObservables<T>	onCompleted() Notify all clients that this observable has completed
RemoteObservables<T>	onError(java.lang.Exception exception) Notify all clients of error
RemoteObservables<T>	onNext(T data) Send the given data to all clients that created using newObservable()

Methods inherited from class java.lang.Object

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

Method Detail

of

public static <T> RemoteObservables<T> of(java.lang.Object type)

Returns RemoteObservables tied to the given type

newObservable

public RemoteObservable<T> newObservable()

Creates a new RemoteObservable to return to client By default this observable will emit every data that is send using onNext(Object)

Returns:

a new instance of RemoteObservable to return to client

newObservable

public RemoteObservable<T> newObservable(boolean ignoreDuplicates)

Creates a new RemoteObservable to return to client. To send data use onNext(Object)

Parameters:

ignoreDuplicates - Whether this observable to ignore duplicates send to it

Returns:

a new instance of RemoteObservable to return to client

onNext

public RemoteObservables<T> onNext(T data)

Send the given data to all clients that created using newObservable()

Parameters:

data - data to send

onCompleted

public RemoteObservables<T> onCompleted()

Notify all clients that this observable has completed

onError

public RemoteObservables<T> onError(java.lang.Exception exception)

Notify all clients of error