Top Description Fields Constructors Methods
rx.internal.util

public final Class ActionObserver<T>

extends Object
implements Observer<T>
Class Inheritance
All Implemented Interfaces
rx.Observer
Type Parameters
<T>
the value type
Imports
rx.Observer, rx.functions.*
An Observer that forwards the onXXX method calls to callbacks.

Field Summary

Modifier and TypeField and Description
pack-priv final Action0
onCompleted

pack-priv final Action1<? super Throwable>
onError

pack-priv final Action1<? super T>
onNext

Constructor Summary

AccessConstructor and Description
public
ActionObserver(Action1<? super T> onNext, Action1<? super Throwable> onError, Action0 onCompleted)

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
e)

Implements rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(T
the item emitted by the Observable
t)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

onCompletedback to summary
pack-priv final Action0 onCompleted
onErrorback to summary
pack-priv final Action1<? super Throwable> onError
onNextback to summary
pack-priv final Action1<? super T> onNext

Constructor Detail

ActionObserverback to summary
public ActionObserver(Action1<? super T> onNext, Action1<? super Throwable> onError, Action0 onCompleted)

Method Detail

onCompletedback to summary
public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters
e:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override