Package software.amazon.awssdk.utils.async

Class InputStreamConsumingPublisher

java.lang.Object

software.amazon.awssdk.utils.async.InputStreamConsumingPublisher

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>

public class InputStreamConsumingPublisher
extends Object
implements org.reactivestreams.Publisher<ByteBuffer>

A publisher to which an InputStream can be written.

See doBlockingWrite(InputStream).

Constructor Summary

Constructors

Constructor	Description
InputStreamConsumingPublisher()

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancel an ongoing doBlockingWrite(InputStream) call.
long	doBlockingWrite(InputStream inputStream)	Write the provided input stream to the stream subscribed to this publisher.
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)

Methods inherited from class java.lang.Object

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

Constructor Details

InputStreamConsumingPublisher

public InputStreamConsumingPublisher()

Method Details

doBlockingWrite

public long doBlockingWrite(InputStream inputStream)

Write the provided input stream to the stream subscribed to this publisher.

This method will block the calling thread to write until: (1) the provided input stream is fully consumed, (2) the subscription is cancelled, (3) reading from the input stream fails, or (4) cancel() is called.

Returns:

The amount of data written to the downstream subscriber.

cancel

public void cancel()

Cancel an ongoing doBlockingWrite(InputStream) call.

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>