io.reactivex.rxjava3.internal.observers

public Interface InnerQueuedObserverSupport<T>

Known Direct Implementers

Type Parameters

Interface to allow the InnerQueuedSubscriber to call back a parent with signals.

Method Summary

Modifier and Type	Method and Description
public void	drain()
public void	innerComplete(InnerQueuedObserver<T> inner)
public void	innerError(InnerQueuedObserver<T> inner, Throwable e)
public void	innerNext(InnerQueuedObserver<T> inner, T value)

drain	back to summary
public void drain()

innerComplete	back to summary
public void innerComplete(InnerQueuedObserver<T> inner)

innerError	back to summary
public void innerError(InnerQueuedObserver<T> inner, Throwable e)

innerNext	back to summary
public void innerNext(InnerQueuedObserver<T> inner, T value)