Package-level declarations

A resource than can be closed. The close method is invoked to release resources an object is holding (e.g. such as open files)

Indicates attempt to write on a closed channel (i.e. SdkByteWriteChannel.isClosedForWrite == true) that was closed without a cause. A failed channel rethrows the original SdkByteWriteChannel.close cause exception on send attempts.

Wraps the SdkByteReadChannel so that it compresses into gzip format with each read.

Wraps the SdkByteReadChannel so that it compresses into gzip format with each read.

Wraps the SdkSource so that it compresses into gzip format with each read.

Wraps the SdkSource so that it compresses into gzip format with each read.

Handler is an (asynchronous) transform from Request ->Response

A collection of bytes in memory. Moving data from one buffer to another is fast.

A sink that keeps a buffer internally so that callers can do small writes without a performance penalty.

A sink that keeps a buffer internally so that callers can do small writes without a performance penalty.

A source that keeps a buffer internally such that small reads are performant. It also allows peeking ahead, buffering data as necessary, before consuming it.

Channel for asynchronous reading and writing sequences of bytes. Conceptually a pipe with a reader on one end, decoupled from a writer on the other.

Supplies an asynchronous stream of bytes. This is a single-reader channel.

A channel for writing a sequence of bytes asynchronously. This is a single writer channel.

Interface that the lifecycle of some resource is managed by the SDK at runtime.

A destination for writing a stream of bytes (e.g. file, network, in-memory buffer). Sinks may be layered to transform received data, such as to compress, encrypt, throttle, or add protocol framing.

A source for reading a stream of bytes (e.g. from file, network, or in-memory buffer). Sources may be layered to transform data as it is read (e.g. to decompress, decrypt, or remove protocol framing).

Returns a new sink that buffers writes to the sink. Writes will be efficiently "batched". Call SdkSink.flush when done to emit all data to the underlying sink.

Returns a new source that buffers reads from the underlying source. The returned source will perform bulk reads to an in-memory buffer making small reads efficient.

Read all bytes from this channel into sink. Returns the total number of bytes written.

Read exactly byteCount bytes from this into sink or throws EOFException if the channel is exhausted before all bytes could be read.

Remove exactly byteCount bytes from this source and appends them to sink.

Caution Read the entire contents of the channel into sink. This function will suspend until the channel is exhausted and no bytes remain OR the channel cancelled

Caution Read the entire contents of the channel into a new buffer and return it. This function will suspend until the channel is exhausted and no bytes remain OR the channel cancelled

Create a new SdkSink that writes to this file

Create a new SdkSource that reads from this InputStream

Create a new SdkSink that writes to the file represented by this path

Returns a new source that reads from the underlying ByteArray

Create a new SdkSource that reads from this InputStream

Create an SdkSource from the given file and range

Create a SdkSource from the given path and range

Create a blocking InputStream that blocks everytime the channel suspends at SdkByteReadChannel.read

Executes the given block on this resource and then closes it whether an exception has occurred or not.

Write limit bytes from source starting at offset. Suspends until all bytes can be written.

Removes all bytes from source and writes them to this channel. Returns the total number of bytes read.

Convenience function to write as many bytes from source as possible without suspending. Returns the number of bytes that could be written.