Interface InnerQueuedSubscriberSupport<T>
- Type Parameters:
T
- the value type
- All Known Implementing Classes:
FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber
public interface InnerQueuedSubscriberSupport<T>
Interface to allow the InnerQueuedSubscriber to call back a parent
with signals.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
drain()
void
innerComplete
(InnerQueuedSubscriber<T> inner) void
innerError
(InnerQueuedSubscriber<T> inner, Throwable e) void
innerNext
(InnerQueuedSubscriber<T> inner, T value)
-
Method Details
-
innerNext
-
innerError
-
innerComplete
-
drain
void drain()
-