Module methanol

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

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

downstream, 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

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>