Module methanol

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

Class TimeoutBodySubscriber<T>

java.lang.Object

com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber<T>

com.github.mizosoft.methanol.internal.flow.SerializedForwardingSubscriber<T>

com.github.mizosoft.methanol.internal.flow.TimeoutSubscriber<java.util.List<java.nio.ByteBuffer>,java.net.http.HttpResponse.BodySubscriber<T>>

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

All Implemented Interfaces:

java.net.http.HttpResponse.BodySubscriber<T>, java.util.concurrent.Flow.Subscriber<java.util.List<java.nio.ByteBuffer>>

public final class TimeoutBodySubscriber<T>
extends TimeoutSubscriber<java.util.List<java.nio.ByteBuffer>,java.net.http.HttpResponse.BodySubscriber<T>>
implements java.net.http.HttpResponse.BodySubscriber<T>

Field Summary

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

upstream

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletionStage<T>	getBody()
protected java.lang.Throwable	timeoutError(long index, java.time.Duration timeout)

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

delegate, onComplete, onError, onNext, onSubscribe

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

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 Detail

TimeoutBodySubscriber

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

Method Detail

timeoutError

protected java.lang.Throwable timeoutError(long index,
                                           java.time.Duration timeout)

Specified by:

timeoutError in class TimeoutSubscriber<java.util.List<java.nio.ByteBuffer>,java.net.http.HttpResponse.BodySubscriber<T>>

getBody

public java.util.concurrent.CompletionStage<T> getBody()

Specified by:

getBody in interface java.net.http.HttpResponse.BodySubscriber<T>