Package-level declarations

Types

Link copied to clipboard
abstract class BaseStreamSender<T>(destination: StreamDestination<T>)
Link copied to clipboard
class ByteStreamSender(val info: ByteStreamInfo, destination: StreamDestination<ByteArray>) : BaseStreamSender<ByteArray>

A stream sender for sending byte-based messages (e.g. files, images, etc.)

Link copied to clipboard
Link copied to clipboard
class TextStreamSender(val info: TextStreamInfo, destination: StreamDestination<String>) : BaseStreamSender<String>

Functions

Link copied to clipboard
inline suspend fun <S : BaseStreamSender<*>, R> useStreamSender(sender: S, block: suspend S.() -> R): Result<R>

Runs block with sender, then ensures sender is closed afterwards if it is still open.

Link copied to clipboard

Reads the input stream and sends it to the data stream.

suspend fun ByteStreamSender.write(source: Source): Result<Unit>

Reads the source and sends it to the data stream.

Link copied to clipboard

Reads the file and writes it to the data stream.

Reads the file from filePath and writes it to the data stream.