Class AsyncBodyDecoder<T>

java.lang.Object

com.github.mizosoft.methanol.decoder.AsyncBodyDecoder<T>

All Implemented Interfaces:

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

public final class AsyncBodyDecoder<T>
extends Object
implements BodyDecoder<T>

An implementation of BodyDecoder that uses an AsyncDecoder for decompression. The implementation disallows left-over bytes after the final source is acknowledged, completing the downstream with an IOException on such case. The decoder is closed on either normal or exceptional completion or on cancellation from downstream.

Nested Class Summary

Nested classes/interfaces inherited from interface BodyDecoder

BodyDecoder.Factory

Constructor Summary

Constructors

Constructor	Description
AsyncBodyDecoder(AsyncDecoder decoder, HttpResponse.BodySubscriber<T> downstream)	Creates an AsyncBodyDecoder in sync mode.
AsyncBodyDecoder(AsyncDecoder decoder, HttpResponse.BodySubscriber<T> downstream, Executor executor)	Creates an AsyncBodyDecoder that supplies downstream items in the given executor.
AsyncBodyDecoder(AsyncDecoder decoder, HttpResponse.BodySubscriber<T> downstream, Executor executor, int bufferSize)	Creates an AsyncBodyDecoder that supplies downstream items in the given executor.

Method Summary

Modifier and Type	Method	Description
AsyncDecoder	asyncDecoder()	Returns the underlying AsyncDecoder.
HttpResponse.BodySubscriber<T>	downstream()	Returns this decoder's downstream.
String	encoding()	Returns the encoding used by this decoder.
Optional<Executor>	executor()	Returns this decoder's executor if one is specified.
void	onComplete()
void	onError(Throwable throwable)
void	onNext(List<ByteBuffer> buffers)
void	onSubscribe(Flow.Subscription upstreamSubscription)

Methods inherited from class Object

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

Methods inherited from interface BodyDecoder

getBody

Constructor Details

AsyncBodyDecoder

public AsyncBodyDecoder(AsyncDecoder decoder,
 HttpResponse.BodySubscriber<T> downstream)

Creates an AsyncBodyDecoder in sync mode.

AsyncBodyDecoder

public AsyncBodyDecoder(AsyncDecoder decoder,
 HttpResponse.BodySubscriber<T> downstream,
 Executor executor)

Creates an AsyncBodyDecoder that supplies downstream items in the given executor.

AsyncBodyDecoder

public AsyncBodyDecoder(AsyncDecoder decoder,
 HttpResponse.BodySubscriber<T> downstream,
 Executor executor,
 int bufferSize)

Creates an AsyncBodyDecoder that supplies downstream items in the given executor.

Method Details

asyncDecoder

public AsyncDecoder asyncDecoder()

Returns the underlying AsyncDecoder.

encoding

public String encoding()

Description copied from interface: BodyDecoder

Returns the encoding used by this decoder. This corresponds to the value of the Content-Type header.

Specified by:

encoding in interface BodyDecoder<T>

executor

public Optional<Executor> executor()

Description copied from interface: BodyDecoder

Returns this decoder's executor if one is specified.

Specified by:

executor in interface BodyDecoder<T>

downstream

public HttpResponse.BodySubscriber<T> downstream()

Description copied from interface: BodyDecoder

Returns this decoder's downstream.

Specified by:

downstream in interface BodyDecoder<T>

onSubscribe

public void onSubscribe(Flow.Subscription upstreamSubscription)

Specified by:

onSubscribe in interface Flow.Subscriber<T>

onNext

public void onNext(List<ByteBuffer> buffers)

Specified by:

onNext in interface Flow.Subscriber<T>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface Flow.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<T>