Class FlowableFlatMap.InnerSubscriber<T,U>
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription>
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMap.InnerSubscriber<T,U>
-
- All Implemented Interfaces:
FlowableSubscriber<U>,Disposable,java.io.Serializable,org.reactivestreams.Subscriber<U>
- Enclosing class:
- FlowableFlatMap<T,U>
static final class FlowableFlatMap.InnerSubscriber<T,U> extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements FlowableSubscriber<U>, Disposable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) intbufferSize(package private) booleandone(package private) intfusionMode(package private) longid(package private) intlimit(package private) FlowableFlatMap.MergeSubscriber<T,U>parent(package private) longproduced(package private) SimpleQueue<U>queueprivate static longserialVersionUID
-
Constructor Summary
Constructors Constructor Description InnerSubscriber(FlowableFlatMap.MergeSubscriber<T,U> parent, int bufferSize, long id)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddispose()Dispose the resource, the operation should be idempotent.booleanisDisposed()Returns true if this resource has been disposed.voidonComplete()voidonError(java.lang.Throwable t)voidonNext(U t)voidonSubscribe(org.reactivestreams.Subscription s)Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)is established before callingSubscription.request(long).(package private) voidrequestMore(long n)-
Methods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
id
final long id
-
parent
final FlowableFlatMap.MergeSubscriber<T,U> parent
-
limit
final int limit
-
bufferSize
final int bufferSize
-
done
volatile boolean done
-
queue
volatile SimpleQueue<U> queue
-
produced
long produced
-
fusionMode
int fusionMode
-
-
Constructor Detail
-
InnerSubscriber
InnerSubscriber(FlowableFlatMap.MergeSubscriber<T,U> parent, int bufferSize, long id)
-
-
Method Detail
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription s)
Description copied from interface:FlowableSubscriberImplementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)is established before callingSubscription.request(long). In practice this means no initialization should happen after therequest()call and additional behavior is thread safe in respect toonNext.- Specified by:
onSubscribein interfaceFlowableSubscriber<T>- Specified by:
onSubscribein interfaceorg.reactivestreams.Subscriber<T>
-
onError
public void onError(java.lang.Throwable t)
- Specified by:
onErrorin interfaceorg.reactivestreams.Subscriber<T>
-
onComplete
public void onComplete()
- Specified by:
onCompletein interfaceorg.reactivestreams.Subscriber<T>
-
requestMore
void requestMore(long n)
-
dispose
public void dispose()
Description copied from interface:DisposableDispose the resource, the operation should be idempotent.- Specified by:
disposein interfaceDisposable
-
isDisposed
public boolean isDisposed()
Description copied from interface:DisposableReturns true if this resource has been disposed.- Specified by:
isDisposedin interfaceDisposable- Returns:
- true if this resource has been disposed
-
-