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

public final Class ObservableDoAfterNext<T>

extends AbstractObservableWithUpstream<T, T>
Class Inheritance
Type Parameters
<T>
the value type
Imports
io.reactivex.rxjava3.annotations.Nullable, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.functions.Consumer, io.reactivex.rxjava3.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.rxjava3.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> observer)

Inherited from io.reactivex.rxjava3.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)
Annotations
@Override
io.reactivex.rxjava3.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.rxjava3.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.rxjava3.core.Observer.onNext.

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

Implements io.reactivex.rxjava3.operators.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.rxjava3.operators.QueueFuseable.requestFusion.

Request a fusion mode from the upstream.
Inherited from io.reactivex.rxjava3.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.rxjava3.core.Observer.onNext.

Doc from io.reactivex.rxjava3.core.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 Throwable

Implements io.reactivex.rxjava3.operators.SimpleQueue.poll.

Doc from io.reactivex.rxjava3.operators.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
Throwable:
if some pre-processing of the dequeued item (usually through fused functions) throws.
requestFusionback to summary
public int requestFusion(int mode)

Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion.

Doc from io.reactivex.rxjava3.operators.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