BaseStreamReceiver

abstract class BaseStreamReceiver<T>(source: Channel<ByteArray>)

Constructors

constructor(source: Channel<ByteArray>)

abstract val flow: Flow<T>

suspend fun readAll(): List<T>

Suspends and waits for all available data until the stream is closed.

suspend fun readNext(): T

Suspends and waits for the next piece of data.