Class AsyncSubscriberAdapter<T, S extends Flow.Subscriber<? super List<ByteBuffer>>>

java.lang.Object

com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber<List<ByteBuffer>>

com.github.mizosoft.methanol.internal.extensions.AsyncSubscriberAdapter<T,S>

Type Parameters:

T - the body type

S - the subscriber's type

All Implemented Interfaces:

HttpResponse.BodySubscriber<T>, Flow.Subscriber<List<ByteBuffer>>

public final class AsyncSubscriberAdapter<T, S extends Flow.Subscriber<? super List<ByteBuffer>>>
extends ForwardingSubscriber<List<ByteBuffer>>
implements HttpResponse.BodySubscriber<T>

Adapts a subscriber to a BodySubscriber where the body's completion need not be in accordance with onComplete or onError.

Field Summary

Fields inherited from class ForwardingSubscriber

upstream

Constructor Summary

Constructors

Constructor	Description
AsyncSubscriberAdapter(S downstream, Function<? super S, ? extends CompletionStage<T>> asyncFinisher)

Method Summary

Modifier and Type	Method	Description
protected Flow.Subscriber<? super List<ByteBuffer>>	delegate()	Returns the downstream to which signals are forwarded.
CompletionStage<T>	getBody()

Methods inherited from class ForwardingSubscriber

onComplete, onError, onNext, onSubscribe, toString

Methods inherited from class Object

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

Methods inherited from interface Flow.Subscriber

onComplete, onError, onNext, onSubscribe

Constructor Details

AsyncSubscriberAdapter

public AsyncSubscriberAdapter(S downstream,
 Function<? super S, ? extends CompletionStage<T>> asyncFinisher)

Method Details

delegate

protected Flow.Subscriber<? super List<ByteBuffer>> 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>