C D G I N O R S W

C

close() - Method in class io.reactivex.remote.RemoteObservable

Close this RemoteObservable No further events will be delivered

CREATOR - Static variable in class io.reactivex.remote.RemoteObservable

D

describeContents() - Method in class io.reactivex.remote.RemoteObservable

G

getData() - Method in class io.reactivex.remote.RemoteObservable

Returns the last data received, blocking until one is available.

getData(boolean) - Method in class io.reactivex.remote.RemoteObservable

Returns the last data received, optionally blocking till the data is received

getObservable() - Method in class io.reactivex.remote.RemoteObservable

Returns an Observable which will receive the data send from the service side.

getRemoteEventManager() - Method in class io.reactivex.remote.RemoteEventController

I

io.reactivex.remote - package io.reactivex.remote

RxRemote extends the power of Rx Observables across android process.

N

newObservable() - Method in class io.reactivex.remote.RemoteObservables

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

newObservable(boolean) - Method in class io.reactivex.remote.RemoteObservables

Creates a new RemoteObservable to return to client.

O

of(Object) - Static method in class io.reactivex.remote.RemoteObservables

Returns RemoteObservables tied to the given type

onClosed() - Method in class io.reactivex.remote.RemoteEventController

Override this to know when the client closed the remote observable.

onClosed() - Method in class io.reactivex.remote.RemoteObservableListener

Override this to know when the client closed the remote observable.

onCompleted() - Method in class io.reactivex.remote.RemoteObservables

Notify all clients that this observable has completed

onData(T) - Method in interface io.reactivex.remote.RemoteDataListener

Called when a data update is received

onError(Exception) - Method in class io.reactivex.remote.RemoteObservables

Notify all clients of error

onNext(T) - Method in class io.reactivex.remote.RemoteObservables

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

onSubscribed() - Method in class io.reactivex.remote.RemoteEventController

Override this to know when first client subscribed to the observable

onSubscribed() - Method in class io.reactivex.remote.RemoteObservableListener

Override this to know when first client subscribed to the observable

onUnsubscribe() - Method in class io.reactivex.remote.RemoteObservableListener

Called when ALL clients have unsubscribed.

onUnSubscribed() - Method in class io.reactivex.remote.RemoteEventController

Override this to know when ALL clients have unsubscribed.

R

RemoteDataListener<T> - Interface in io.reactivex.remote

Listener on the client side to get notified when the data is updated from server side.

RemoteEventController<T> - Class in io.reactivex.remote

Use this class to send the data at the server side that needs to be delivered to the rx.Observable at the client side.

RemoteEventController() - Constructor for class io.reactivex.remote.RemoteEventController

Create a default instance of RemoteEventController Use RemoteEventController.sendEvent(Object), RemoteEventController.sendCompleted() to send the data

RemoteEventController(<any>) - Constructor for class io.reactivex.remote.RemoteEventController

Creates an instance of RemoteEventController with the given Observable

RemoteObservable<T> - Class in io.reactivex.remote

Observable across android remote services.

RemoteObservable(RemoteEventController<T>) - Constructor for class io.reactivex.remote.RemoteObservable

Initialize at the service side with the RemoteEventController

RemoteObservable(<any>) - Constructor for class io.reactivex.remote.RemoteObservable

Initialize at the service side with an Observable

RemoteObservableListener - Class in io.reactivex.remote

Listen for the remote close events

RemoteObservableListener() - Constructor for class io.reactivex.remote.RemoteObservableListener

RemoteObservables<T> - Class in io.reactivex.remote

Helper class to create RemoteObservable and send data through it

S

sendCompleted() - Method in class io.reactivex.remote.RemoteEventController

Generate an onCompleted event at the client observable.

sendError(Exception) - Method in class io.reactivex.remote.RemoteEventController

Generate an onError event at the client observable.

sendEvent(T) - Method in class io.reactivex.remote.RemoteEventController

Send the given data to the client observable

setDataListener(RemoteDataListener<T>) - Method in class io.reactivex.remote.RemoteObservable

Sets a listener to get notified of data.

setDebug(boolean) - Method in class io.reactivex.remote.RemoteEventController

Enable or disable debug prints.

setDebug(boolean) - Method in class io.reactivex.remote.RemoteObservable

Enable or disable debug prints.

setIgnoreIfDuplicateOfLast(boolean) - Method in class io.reactivex.remote.RemoteEventController

If set, the RemoteEventController.sendEvent(Object) wont be delivered if it is same as last event.

setReconnecter(Callable<RemoteObservable<T>>) - Method in class io.reactivex.remote.RemoteObservable

Sets a Callable to be used to reconnect if the connection with the remote service dies.

setRemoteObservableListener(RemoteObservableListener) - Method in class io.reactivex.remote.RemoteEventController

setRemoteObservableListener(RemoteObservableListener) - Method in class io.reactivex.remote.RemoteObservable

Set the listener to get notified when remote end closes connection.

W

writeToParcel(Parcel, int) - Method in class io.reactivex.remote.RemoteObservable

C D G I N O R S W