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

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 com.github.mizosoft.methanol.internal.flow.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 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
- 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>

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

Field Summary