Class TimeoutBodySubscriber<T>

java.lang.Object

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

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

com.github.mizosoft.methanol.internal.flow.TimeoutSubscriber<List<ByteBuffer>, HttpResponse.BodySubscriber<T>>

com.github.mizosoft.methanol.internal.extensions.TimeoutBodySubscriber<T>

All Implemented Interfaces:

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

public final class TimeoutBodySubscriber<T>
extends TimeoutSubscriber<List<ByteBuffer>, HttpResponse.BodySubscriber<T>>
implements HttpResponse.BodySubscriber<T>

Field Summary

Fields inherited from class ForwardingSubscriber

upstream

Constructor Summary

Constructors

Constructor	Description
TimeoutBodySubscriber(HttpResponse.BodySubscriber<T> downstream, Duration timeout, Delayer delayer)

Method Summary

Modifier and Type	Method	Description
CompletionStage<T>	getBody()
protected Throwable	timeoutError(long index, Duration timeout)

Methods inherited from class TimeoutSubscriber

delegate, onComplete, onError, onNext, onSubscribe

Methods inherited from class ForwardingSubscriber

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

TimeoutBodySubscriber

public TimeoutBodySubscriber(HttpResponse.BodySubscriber<T> downstream,
 Duration timeout,
 Delayer delayer)

Method Details

timeoutError

protected Throwable timeoutError(long index,
 Duration timeout)

Specified by:

timeoutError in class TimeoutSubscriber<List<ByteBuffer>, HttpResponse.BodySubscriber<T>>

getBody

public CompletionStage<T> getBody()

Specified by:

getBody in interface HttpResponse.BodySubscriber<T>