Module methanol

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

Class ByteChannelSubscriber

java.lang.Object

com.github.mizosoft.methanol.internal.extensions.ByteChannelSubscriber

All Implemented Interfaces:

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

public final class ByteChannelSubscriber
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
ByteChannelSubscriber()	Creates a new completed ByteChannelSubscriber instance.

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 java.lang.Object

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

Constructor Details

ByteChannelSubscriber

public ByteChannelSubscriber()

Creates a new completed ByteChannelSubscriber instance.

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