Class BlockingFlowableNext.NextSubscriber<T>
java.lang.Object
io.reactivex.rxjava3.subscribers.DisposableSubscriber<Notification<T>>
io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableNext.NextSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<Notification<T>>
,Disposable
,org.reactivestreams.Subscriber<Notification<T>>
- Enclosing class:
BlockingFlowableNext<T>
static final class BlockingFlowableNext.NextSubscriber<T>
extends DisposableSubscriber<Notification<T>>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BlockingQueue
<Notification<T>> (package private) final AtomicInteger
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
void
onNext
(Notification<T> args) (package private) void
takeNext()
Methods inherited from class io.reactivex.rxjava3.subscribers.DisposableSubscriber
cancel, dispose, isDisposed, onStart, onSubscribe, request
-
Field Details
-
buf
-
waiting
-
-
Constructor Details
-
NextSubscriber
NextSubscriber()
-
-
Method Details
-
onComplete
public void onComplete() -
onError
-
onNext
-
takeNext
- Throws:
InterruptedException
-
setWaiting
void setWaiting()
-