Top Description Inners Fields Constructors Methods
rx.internal.operators

public Class OnSubscribeDoOnEach<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type
Imports
java.util.Arrays, rx.*, .Observable.OnSubscribe, rx.exceptions.*, rx.plugins.RxJavaHooks
Calls specified actions for each notification.

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
OnSubscribeDoOnEach.DoOnEachSubscriber<T>

Field Summary

Modifier and TypeField and Description
private final Observer<? super T>
doOnEachObserver

private final Observable<T>
source

Constructor Summary

AccessConstructor and Description
public
OnSubscribeDoOnEach(Observable<T> source, Observer<? super T> doOnEachObserver)

Method Summary

Modifier and TypeMethod and Description
public void
call(final Subscriber<? super T> subscriber)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

doOnEachObserverback to summary
private final Observer<? super T> doOnEachObserver
sourceback to summary
private final Observable<T> source

Constructor Detail

OnSubscribeDoOnEachback to summary
public OnSubscribeDoOnEach(Observable<T> source, Observer<? super T> doOnEachObserver)

Method Detail

callback to summary
public void call(final Subscriber<? super T> subscriber)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

private final Class OnSubscribeDoOnEach.DoOnEachSubscriber<T>

extends Subscriber<T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
private boolean
done

private final Observer<? super T>
doOnEachObserver

private final Subscriber<? super T>
subscriber

Hides rx.Subscriber.subscriber.

Constructor Summary

AccessConstructor and Description
pack-priv
DoOnEachSubscriber(Subscriber<? super T> subscriber, Observer<? super T> doOnEachObserver)

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
value)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from rx.Subscriber:
addisUnsubscribedonStartrequestsetProducerunsubscribe

Field Detail

doneback to summary
private boolean done
doOnEachObserverback to summary
private final Observer<? super T> doOnEachObserver
subscriberback to summary
private final Subscriber<? super T> subscriber

Hides rx.Subscriber.subscriber.

Constructor Detail

DoOnEachSubscriberback to summary
pack-priv DoOnEachSubscriber(Subscriber<? super T> subscriber, Observer<? super T> doOnEachObserver)

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 value)

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
value:T

the item emitted by the Observable

Annotations
@Override