Module methanol

Package com.github.mizosoft.methanol.internal.extensions

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

Constructors

Modifier	Constructor	Description
protected	ForwardingBodySubscriber(HttpResponse.BodySubscriber<T> delegate)

Method Summary

Modifier and Type	Method	Description
protected final HttpResponse.BodySubscriber<T>	delegate()	Returns the downstream to which signals are forwarded.
CompletionStage<T>	getBody()

Methods inherited from class com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber

onComplete, onError, onNext, onSubscribe, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.Flow.Subscriber

onComplete, onError, onNext, onSubscribe

Constructor Details

ForwardingBodySubscriber

protected ForwardingBodySubscriber(HttpResponse.BodySubscriber<T> delegate)

Method Details

delegate

protected final HttpResponse.BodySubscriber<T> delegate()

Description copied from class: ForwardingSubscriber

Returns the downstream to which signals are forwarded.

Specified by:

delegate in class ForwardingSubscriber<List<ByteBuffer>>

getBody

public CompletionStage<T> getBody()

Specified by:

getBody in interface HttpResponse.BodySubscriber<T>