java.lang.Object
com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber<T>
- All Implemented Interfaces:
Flow.Subscriber<T>
- Direct Known Subclasses:
AsyncSubscriberAdapter
,ForwardingBodySubscriber
,SerializedForwardingSubscriber
A
Subscriber<T>
that forwards to a downstream Subscriber<? super T>
.-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected abstract Flow.Subscriber
<? super T> Returns the downstream to which signals are forwarded.void
void
void
void
onSubscribe
(Flow.Subscription subscription)
-
Field Details
-
upstream
-
-
Constructor Details
-
ForwardingSubscriber
protected ForwardingSubscriber()
-
-
Method Details
-
downstream
Returns the downstream to which signals are forwarded. -
onSubscribe
- Specified by:
onSubscribe
in interfaceFlow.Subscriber<T>
-
onNext
- Specified by:
onNext
in interfaceFlow.Subscriber<T>
-
onError
- Specified by:
onError
in interfaceFlow.Subscriber<T>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceFlow.Subscriber<T>
-