Package rx.observers
Class Observers
java.lang.Object
rx.observers.Observers
Helper methods and utilities for creating and working with
Observer
objects.-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> Observer
<T> Creates anObserver
that receives the emissions of anyObservable
it subscribes to viaonNext
but ignoresonCompleted
notifications; it will throw anOnErrorNotImplementedException
ifonError
is invoked.static <T> Observer
<T> Creates anObserver
that receives the emissions of anyObservable
it subscribes to viaonNext
and handles anyonError
notification but ignores anonCompleted
notification.static <T> Observer
<T> Creates anObserver
that receives the emissions of anyObservable
it subscribes to viaonNext
and handles anyonError
oronCompleted
notifications.static <T> Observer
<T> empty()
-
Field Details
-
EMPTY
-
-
Constructor Details
-
Observers
private Observers()
-
-
Method Details
-
empty
Returns an inertObserver
that does nothing in response to the emissions or notifications from anyObservable
it subscribes to but will throw an exception if itsonError
method is called.- Type Parameters:
T
- the observed value type- Returns:
- an inert
Observer
-
create
Creates anObserver
that receives the emissions of anyObservable
it subscribes to viaonNext
but ignoresonCompleted
notifications; it will throw anOnErrorNotImplementedException
ifonError
is invoked.- Type Parameters:
T
- the observed value type- Parameters:
onNext
- a function that handles each item emitted by anObservable
- Returns:
- an
Observer
that callsonNext
for each emitted item from theObservable
theObserver
subscribes to - Throws:
IllegalArgumentException
- ifonNext
isnull
-
create
Creates anObserver
that receives the emissions of anyObservable
it subscribes to viaonNext
and handles anyonError
notification but ignores anonCompleted
notification.- Type Parameters:
T
- the observed value type- Parameters:
onNext
- a function that handles each item emitted by anObservable
onError
- a function that handles an error notification if one is sent by anObservable
- Returns:
- an
Observer
that callsonNext
for each emitted item from theObservable
theObserver
subscribes to, and callsonError
if theObservable
notifies of an error - Throws:
IllegalArgumentException
- if eitheronNext
oronError
arenull
-
create
public static <T> Observer<T> create(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onComplete) Creates anObserver
that receives the emissions of anyObservable
it subscribes to viaonNext
and handles anyonError
oronCompleted
notifications.- Type Parameters:
T
- the observed value type- Parameters:
onNext
- a function that handles each item emitted by anObservable
onError
- a function that handles an error notification if one is sent by anObservable
onComplete
- a function that handles a sequence complete notification if one is sent by anObservable
- Returns:
- an
Observer
that callsonNext
for each emitted item from theObservable
theObserver
subscribes to, callsonError
if theObservable
notifies of an error, and callsonComplete
if theObservable
notifies that the observable sequence is complete - Throws:
IllegalArgumentException
- if eitheronNext
,onError
, oronComplete
arenull
-