Package software.amazon.awssdk.utils.async

Class OutputStreamPublisher

java.lang.Object

java.io.OutputStream

software.amazon.awssdk.utils.CancellableOutputStream

software.amazon.awssdk.utils.async.OutputStreamPublisher

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, org.reactivestreams.Publisher<ByteBuffer>

public final class OutputStreamPublisher
extends CancellableOutputStream
implements org.reactivestreams.Publisher<ByteBuffer>

Adapts a Publisher to an OutputStream.

Writes to the stream will block until demand is available in the downstream subscriber.

Constructor Summary

Constructors

Constructor	Description
OutputStreamPublisher()

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancel writing to the stream.
void	close()
void	flush()
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.lang.Object

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

Constructor Details

OutputStreamPublisher

public OutputStreamPublisher()

Method Details

write

public void write(int b)

Specified by:

write in class OutputStream

write

public void write(byte[] b)

Overrides:

write in class OutputStream

write

public void write(byte[] b,
 int off,
 int len)

Overrides:

write in class OutputStream

flush

public void flush()

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

cancel

public void cancel()

Description copied from class: CancellableOutputStream

Cancel writing to the stream. This is different than OutputStream.close() in that it indicates the data written so far is truncated and incomplete. Callers must still invoke OutputStream.close() even if the stream is cancelled.

Specified by:

cancel in class CancellableOutputStream

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>