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
Fields Modifier and Type Field Description private java.util.concurrent.BlockingQueue<Notification<T>>
buf
(package private) java.util.concurrent.atomic.AtomicInteger
waiting
-
Constructor Summary
Constructors Constructor Description NextSubscriber()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
void
onError(java.lang.Throwable e)
void
onNext(Notification<T> args)
(package private) void
setWaiting()
Notification<T>
takeNext()
-
Methods inherited from class io.reactivex.rxjava3.subscribers.DisposableSubscriber
cancel, dispose, isDisposed, onStart, onSubscribe, request
-
-
-
-
Field Detail
-
buf
private final java.util.concurrent.BlockingQueue<Notification<T>> buf
-
waiting
final java.util.concurrent.atomic.AtomicInteger waiting
-
-
Method Detail
-
onComplete
public void onComplete()
-
onError
public void onError(java.lang.Throwable e)
-
onNext
public void onNext(Notification<T> args)
-
takeNext
public Notification<T> takeNext() throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
setWaiting
void setWaiting()
-
-