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

public final Class FlowableDoAfterNext<T>

extends AbstractFlowableWithUpstream<T, T>
Class Inheritance
Type Parameters
<T>
the value type
Imports
org.reactivestreams.Subscriber, io.reactivex.rxjava3.annotations.Nullable, io.reactivex.rxjava3.core.Flowable, io.reactivex.rxjava3.functions.Consumer, io.reactivex.rxjava3.internal.subscribers.*, io.reactivex.rxjava3.operators.ConditionalSubscriber
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
FlowableDoAfterNext.DoAfterConditionalSubscriber<T>

pack-priv static class
FlowableDoAfterNext.DoAfterSubscriber<T>

Field Summary

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

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream:
source

Constructor Summary

AccessConstructor and Description
public
FlowableDoAfterNext(Flowable<T> source, Consumer<? super T> onAfterNext)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(Subscriber<? super T> s)

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream:
source

Field Detail

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

Constructor Detail

FlowableDoAfterNextback to summary
public FlowableDoAfterNext(Flowable<T> source, Consumer<? super T> onAfterNext)

Method Detail

subscribeActualback to summary
protected void subscribeActual(Subscriber<? super T> s)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.flowable back to summary

pack-priv final Class FlowableDoAfterNext.DoAfterConditionalSubscriber<T>

extends BasicFuseableConditionalSubscriber<T, T>
Class Inheritance

Field Summary

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

Inherited from io.reactivex.rxjava3.internal.subscribers.BasicFuseableConditionalSubscriber:
donedownstreamqssourceModeupstream

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
public void
onNext(T
the element signaled
t)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
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.
public boolean
tryOnNext(T
the value to deliver
t)

Implements io.reactivex.rxjava3.operators.ConditionalSubscriber.tryOnNext.

Conditionally takes the value.
Inherited from io.reactivex.rxjava3.internal.subscribers.BasicFuseableConditionalSubscriber:
afterDownstreambeforeDownstreamcancelclearfailisEmptyofferofferonCompleteonErroronSubscriberequesttransitiveBoundaryFusion

Field Detail

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

Constructor Detail

DoAfterConditionalSubscriberback to summary
pack-priv DoAfterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Consumer<? super T> onAfterNext)

Method Detail

onNextback to summary
public void onNext(T t)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
t:T

the element signaled

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
tryOnNextback to summary
public boolean tryOnNext(T t)

Implements io.reactivex.rxjava3.operators.ConditionalSubscriber.tryOnNext.

Doc from io.reactivex.rxjava3.operators.ConditionalSubscriber.tryOnNext.

Conditionally takes the value.

Parameters
t:T

the value to deliver

Returns:boolean

true if the value has been accepted, false if the value has been rejected and the next value can be sent immediately

Annotations
@Override
io.reactivex.rxjava3.internal.operators.flowable back to summary

pack-priv final Class FlowableDoAfterNext.DoAfterSubscriber<T>

extends BasicFuseableSubscriber<T, T>
Class Inheritance

Field Summary

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

Inherited from io.reactivex.rxjava3.internal.subscribers.BasicFuseableSubscriber:
donedownstreamqssourceModeupstream

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
public void
onNext(T
the element signaled
t)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
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.subscribers.BasicFuseableSubscriber:
afterDownstreambeforeDownstreamcancelclearfailisEmptyofferofferonCompleteonErroronSubscriberequesttransitiveBoundaryFusion

Field Detail

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

Constructor Detail

DoAfterSubscriberback to summary
pack-priv DoAfterSubscriber(Subscriber<? super T> actual, Consumer<? super T> onAfterNext)

Method Detail

onNextback to summary
public void onNext(T t)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
t:T

the element signaled

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