DataSink

Kotlin |Java

@UnstableApi
public interface DataSink

Known direct subclasses

`AesCipherDataSink`	A wrapping `DataSink` that encrypts the data being consumed.
`ByteArrayDataSink`	A `DataSink` for writing to a byte array.
`CacheDataSink`	Writes data into a cache.
`FailOnCloseDataSink`	A `DataSink` that can simulate caching the bytes being written to it, and then failing to persist them when `close` is called.

A component to which streams of data can be written.

Summary

Nested types
`public interface DataSink.Factory` A factory for `DataSink` instances.

Public methods
`abstract void`	`close()` Closes the sink.
`abstract void`	`open(DataSpec dataSpec)` Opens the sink to consume the specified data.
`abstract void`	`write(byte[] buffer, int offset, int length)` Consumes the provided data.

abstract void close()

Closes the sink.

Note: This method must be called even if the corresponding call to open threw an IOException. See open for more details.

Throws
`java.io.IOException`	If an error occurs closing the sink.

abstract void open(DataSpec dataSpec)

Opens the sink to consume the specified data.

Note: If an IOException is thrown, callers must still call close to ensure that any partial effects of the invocation are cleaned up.

Parameters
`DataSpec dataSpec`	Defines the data to be consumed.

Throws
`java.io.IOException`	If an error occurs opening the sink.

abstract void write(byte[] buffer, int offset, int length)

Consumes the provided data.

Parameters
`byte[] buffer`	The buffer from which data should be consumed.
`int offset`	The offset of the data to consume in `buffer`.
`int length`	The length of the data to consume, in bytes.

Throws
`java.io.IOException`	If an error occurs writing to the sink.