Module methanol
Class ForwardingBodySubscriber<T>
java.lang.Object
com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber<List<ByteBuffer>>
com.github.mizosoft.methanol.internal.extensions.ForwardingBodySubscriber<T>
- All Implemented Interfaces:
HttpResponse.BodySubscriber<T>
,Flow.Subscriber<List<ByteBuffer>>
public class ForwardingBodySubscriber<T>
extends ForwardingSubscriber<List<ByteBuffer>>
implements HttpResponse.BodySubscriber<T>
-
Field Summary
Fields inherited from class com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber
upstream
-
Constructor Summary
ModifierConstructorDescriptionprotected
ForwardingBodySubscriber
(HttpResponse.BodySubscriber<T> downstream) -
Method Summary
Modifier and TypeMethodDescriptionprotected final HttpResponse.BodySubscriber
<T> Returns the downstream to which signals are forwarded.getBody()
Methods inherited from class com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber
onComplete, onError, onNext, onSubscribe
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.util.concurrent.Flow.Subscriber
onComplete, onError, onNext, onSubscribe
-
Constructor Details
-
ForwardingBodySubscriber
-
-
Method Details
-
downstream
Description copied from class:ForwardingSubscriber
Returns the downstream to which signals are forwarded.- Specified by:
downstream
in classForwardingSubscriber<List<ByteBuffer>>
-
getBody
- Specified by:
getBody
in interfaceHttpResponse.BodySubscriber<T>
-