Class MoreBodyHandlers

java.lang.Object

com.github.mizosoft.methanol.MoreBodyHandlers

public class MoreBodyHandlers
extends Object

Static factories for additional HttpResponse.BodyHandler implementations.

Method Summary

Modifier and Type	Method	Description
static <T> HttpResponse.BodyHandler<T>	decoding(HttpResponse.BodyHandler<T> downstreamBodyHandler)	Returns a BodyHandler that decompresses the response body for the given handler using a BodyDecoder.
static <T> HttpResponse.BodyHandler<T>	decoding(HttpResponse.BodyHandler<T> downstreamHandler, @Nullable Executor executor)	Returns a BodyHandler that decompresses the response body for the given handler using a BodyDecoder.
static <T, S extends Flow.Subscriber<? super List<ByteBuffer>>> HttpResponse.BodyHandler<T>	fromAsyncSubscriber(S downstream, Function<? super S, ? extends CompletionStage<T>> asyncFinisher)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.fromAsyncSubscriber(Subscriber, Function).
static HttpResponse.BodyHandler<ReadableByteChannel>	ofByteChannel()	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofByteChannel().
static <T> HttpResponse.BodyHandler<Supplier<T>>	ofDeferredObject(TypeRef<T> typeRef)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofDeferredObject(TypeRef, MediaType).
static <T> HttpResponse.BodyHandler<Supplier<T>>	ofDeferredObject(Class<T> type)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofDeferredObject(TypeRef, MediaType).
static <T> HttpResponse.BodyHandler<T>	ofObject(TypeRef<T> typeRef)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofObject(TypeRef, MediaType).
static <T> HttpResponse.BodyHandler<T>	ofObject(Class<T> type)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofObject(TypeRef, MediaType).
static HttpResponse.BodyHandler<Reader>	ofReader()	Returns a BodyHandler that returns a subscriber obtained form MoreBodySubscribers.ofReader(Charset) using the charset specified by the Content-Type header, or UTF-8 if not present.
static HttpResponse.BodyHandler<Reader>	ofReader(Charset charset)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofReader(Charset) using the given charset.
static <T> HttpResponse.BodyHandler<T>	withReadTimeout(HttpResponse.BodyHandler<T> delegate, Duration timeout)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.withReadTimeout(BodySubscriber, Duration).
static <T> HttpResponse.BodyHandler<T>	withReadTimeout(HttpResponse.BodyHandler<T> delegate, Duration timeout, ScheduledExecutorService scheduler)	Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.withReadTimeout(BodySubscriber, Duration, ScheduledExecutorService).

Methods inherited from class Object

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

Method Details

fromAsyncSubscriber

public static <T, S extends Flow.Subscriber<? super List<ByteBuffer>>>
HttpResponse.BodyHandler<T> fromAsyncSubscriber(S downstream,
 Function<? super S, ? extends CompletionStage<T>> asyncFinisher)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.fromAsyncSubscriber(Subscriber, Function).

withReadTimeout

public static <T> HttpResponse.BodyHandler<T> withReadTimeout(HttpResponse.BodyHandler<T> delegate,
 Duration timeout)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.withReadTimeout(BodySubscriber, Duration).

withReadTimeout

public static <T> HttpResponse.BodyHandler<T> withReadTimeout(HttpResponse.BodyHandler<T> delegate,
 Duration timeout,
 ScheduledExecutorService scheduler)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.withReadTimeout(BodySubscriber, Duration, ScheduledExecutorService).

ofByteChannel

public static HttpResponse.BodyHandler<ReadableByteChannel> ofByteChannel()

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofByteChannel(). The response is completed as soon as headers are received.

ofReader

public static HttpResponse.BodyHandler<Reader> ofReader()

Returns a BodyHandler that returns a subscriber obtained form MoreBodySubscribers.ofReader(Charset) using the charset specified by the Content-Type header, or UTF-8 if not present. The response is completed as soon as headers are received.

ofReader

public static HttpResponse.BodyHandler<Reader> ofReader(Charset charset)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofReader(Charset) using the given charset. The response is completed as soon as headers are received.

ofObject

public static <T> HttpResponse.BodyHandler<T> ofObject(Class<T> type)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofObject(TypeRef, MediaType). The media type is parsed from the Content-Type response header if present.

Throws:

UnsupportedOperationException - if no BodyAdapter.Decoder that supports the given type is installed

ofObject

public static <T> HttpResponse.BodyHandler<T> ofObject(TypeRef<T> typeRef)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofObject(TypeRef, MediaType). The media type is parsed from the Content-Type response header if present.

Throws:

UnsupportedOperationException - if no BodyAdapter.Decoder that supports the given type is installed

ofDeferredObject

public static <T>
HttpResponse.BodyHandler<Supplier<T>> ofDeferredObject(Class<T> type)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofDeferredObject(TypeRef, MediaType). The media type is parsed from the Content-Type response header if present. The response is completed as soon as headers are received.

Throws:

UnsupportedOperationException - if no BodyAdapter.Decoder that supports the given type is installed

ofDeferredObject

public static <T>
HttpResponse.BodyHandler<Supplier<T>> ofDeferredObject(TypeRef<T> typeRef)

Returns a BodyHandler that returns a subscriber obtained from MoreBodySubscribers.ofDeferredObject(TypeRef, MediaType). The media type is parsed from the Content-Type response header if present. The response is completed as soon as headers are received.

Throws:

UnsupportedOperationException - if no BodyAdapter.Decoder that supports the given type is installed

decoding

public static <T> HttpResponse.BodyHandler<T> decoding(HttpResponse.BodyHandler<T> downstreamBodyHandler)

Returns a BodyHandler that decompresses the response body for the given handler using a BodyDecoder. The decoder is created using the factory corresponding to the response's Content-Encoding header, throwing an UnsupportedOperationException if no such factory is installed. If the header is not present, the result of the given handler is returned as is.

If the response is compressed, the Content-Encoding and Content-Length headers are stripped before forwarding the ResponseInfo to the given handler.

decoding

public static <T> HttpResponse.BodyHandler<T> decoding(HttpResponse.BodyHandler<T> downstreamHandler,
 @Nullable Executor executor)

Returns a BodyHandler that decompresses the response body for the given handler using a BodyDecoder. The decoder is created using the factory corresponding to the response's Content-Encoding header, throwing an UnsupportedOperationException if no such factory is installed. If the header is not present, the result of the given handler is returned as is.

If the response is compressed, the Content-Encoding and Content-Length headers are stripped before forwarding the ResponseInfo to the given handler.