Top Description Methods
io.reactivex.internal.subscribers

public Interface InnerQueuedSubscriberSupport<T>

Known Direct Implementers
io.reactivex.internal.operators.flowable.FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber
Type Parameters
<T>
the value type

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

Method Summary

Modifier and TypeMethod and Description
public void
public void
public void
public void
innerNext(InnerQueuedSubscriber<T> inner, T value)

Method Detail

drainback to summary
public void drain()
innerCompleteback to summary
public void innerComplete(InnerQueuedSubscriber<T> inner)
innerErrorback to summary
public void innerError(InnerQueuedSubscriber<T> inner, Throwable e)
innerNextback to summary
public void innerNext(InnerQueuedSubscriber<T> inner, T value)