Package io.reactivex.rxjava3.internal.operators.flowable

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

buf

private final java.util.concurrent.BlockingQueue<Notification<T>> buf

waiting

final java.util.concurrent.atomic.AtomicInteger waiting

Constructor Detail

NextSubscriber

NextSubscriber()

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()