Class ByteChannelBodySubscriber

java.lang.Object

com.github.mizosoft.methanol.internal.extensions.ByteChannelBodySubscriber

All Implemented Interfaces:

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

public final class ByteChannelBodySubscriber
extends Object
implements HttpResponse.BodySubscriber<ReadableByteChannel>

A subscriber that exposes the flow of bytes as a ReadableByteChannel. The channel is InterruptibleChannel and either closing it asynchronously or interrupting the reader thread causes blocks on read() to throw the appropriate exception and the upstream to be cancelled. Any errors received from upstream are immediately thrown when reading if detected, even if some bytes were available.

Constructor Summary

Constructors

Constructor	Description
ByteChannelBodySubscriber()

Method Summary

Modifier and Type	Method	Description
CompletionStage<ReadableByteChannel>	getBody()
void	onComplete()
void	onError(Throwable throwable)
void	onNext(List<ByteBuffer> item)
void	onSubscribe(Flow.Subscription subscription)

Methods inherited from class Object

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

Constructor Details

ByteChannelBodySubscriber

public ByteChannelBodySubscriber()

Method Details

getBody

public CompletionStage<ReadableByteChannel> getBody()

Specified by:

getBody in interface HttpResponse.BodySubscriber<ReadableByteChannel>

onSubscribe

public void onSubscribe(Flow.Subscription subscription)

Specified by:

onSubscribe in interface Flow.Subscriber<List<ByteBuffer>>

onNext

public void onNext(List<ByteBuffer> item)

Specified by:

onNext in interface Flow.Subscriber<List<ByteBuffer>>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface Flow.Subscriber<List<ByteBuffer>>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<List<ByteBuffer>>