Top Description Inners Fields Constructors Methods
io.reactivex.internal.operators.observable

public final Class ObservableDoAfterNext<T>

extends AbstractObservableWithUpstream<T, T>
Class Inheritance
Type Parameters
<T>
the value type
Imports
io.reactivex.*, io.reactivex.annotations.Nullable, io.reactivex.functions.Consumer, io.reactivex.internal.observers.BasicFuseableObserver
Calls a consumer after pushing the current item to the downstream.

History: 2.0.1 - experimental

Since
2.1

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ObservableDoAfterNext.DoAfterObserver<T>

Field Summary

Modifier and TypeField and Description
pack-priv final Consumer<? super T>
onAfterNext

Inherited from io.reactivex.internal.operators.observable.AbstractObservableWithUpstream:
source

Constructor Summary

AccessConstructor and Description
public
ObservableDoAfterNext(ObservableSource<T> source, Consumer<? super T> onAfterNext)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(Observer<? super T>
the incoming Observer, never null
observer)

Implements abstract io.reactivex.Observable.subscribeActual.

Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Observers.
Inherited from io.reactivex.internal.operators.observable.AbstractObservableWithUpstream:
source

Field Detail

onAfterNextback to summary
pack-priv final Consumer<? super T> onAfterNext

Constructor Detail

ObservableDoAfterNextback to summary
public ObservableDoAfterNext(ObservableSource<T> source, Consumer<? super T> onAfterNext)

Method Detail

subscribeActualback to summary
protected void subscribeActual(Observer<? super T> observer)

Implements abstract io.reactivex.Observable.subscribeActual.

Doc from io.reactivex.Observable.subscribeActual.

Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Observers.

There is no need to call any of the plugin hooks on the current Observable instance or the Observer; all hooks and basic safeguards have been applied by subscribe(Observer) before this method gets called.

Parameters
observer:Observer<? super T>

the incoming Observer, never null

Annotations
@Override
io.reactivex.internal.operators.observable back to summary

pack-priv final Class ObservableDoAfterNext.DoAfterObserver<T>

extends BasicFuseableObserver<T, T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final Consumer<? super T>
onAfterNext

Inherited from io.reactivex.internal.observers.BasicFuseableObserver:
donedownstreamqdsourceModeupstream

Constructor Summary

AccessConstructor and Description
pack-priv
DoAfterObserver(Observer<? super T> actual, Consumer<? super T> onAfterNext)

Method Summary

Modifier and TypeMethod and Description
public void
onNext(T
the item emitted by the Observable
t)

Implements io.reactivex.Observer.onNext.

Provides the Observer with a new item to observe.
public T
poll()

Implements io.reactivex.internal.fuseable.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.
public int
requestFusion(int
the requested fusion mode, allowed values are SYNC, ASYNC, ANY combined with BOUNDARY (e.g., requestFusion(SYNC | BOUNDARY)).
mode)

Implements io.reactivex.internal.fuseable.QueueFuseable.requestFusion.

Request a fusion mode from the upstream.
Inherited from io.reactivex.internal.observers.BasicFuseableObserver:
afterDownstreambeforeDownstreamcleardisposefailisDisposedisEmptyofferofferonCompleteonErroronSubscribetransitiveBoundaryFusion

Field Detail

onAfterNextback to summary
pack-priv final Consumer<? super T> onAfterNext

Constructor Detail

DoAfterObserverback to summary
pack-priv DoAfterObserver(Observer<? super T> actual, Consumer<? super T> onAfterNext)

Method Detail

onNextback to summary
public void onNext(T t)

Implements io.reactivex.Observer.onNext.

Doc from io.reactivex.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 onComplete or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override
pollback to summary
public T poll() throws Exception

Implements io.reactivex.internal.fuseable.SimpleQueue.poll.

Doc from io.reactivex.internal.fuseable.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.

If the producer uses offer(Object, Object) and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.

Returns:T

the item or null to indicate an empty queue

Annotations
@Nullable
@Override
Exceptions
Exception:
if some pre-processing of the dequeued item (usually through fused functions) throws.
requestFusionback to summary
public int requestFusion(int mode)

Implements io.reactivex.internal.fuseable.QueueFuseable.requestFusion.

Doc from io.reactivex.internal.fuseable.QueueFuseable.requestFusion.

Request a fusion mode from the upstream.

This should be called before onSubscribe returns.

Calling this method multiple times or after onSubscribe finished is not allowed and may result in undefined behavior.

Parameters
mode:int

the requested fusion mode, allowed values are SYNC, ASYNC, ANY combined with BOUNDARY (e.g., requestFusion(SYNC | BOUNDARY)).

Returns:int

the established fusion mode: NONE, SYNC, ASYNC.

Annotations
@Override