Package io.reactivex.rxjava3.internal.observers

Interface InnerQueuedObserverSupport<T>

Type Parameters:

T - the value type

All Known Implementing Classes:

ObservableConcatMapEager.ConcatMapEagerMainObserver

public interface InnerQueuedObserverSupport<T>

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

Method Summary

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

Method Details

innerNext

void innerNext(InnerQueuedObserver<T> inner,
 T value)

innerError

void innerError(InnerQueuedObserver<T> inner,
 Throwable e)

innerComplete

void innerComplete(InnerQueuedObserver<T> inner)

drain

void drain()