OutputStreamSink

abstract class OutputStreamSink(coroutineContext: CoroutineContext = Dispatchers.IO) : AbstractSink

Sink to write data to an OutputStream

Constructors

constructor(coroutineContext: CoroutineContext = Dispatchers.IO)

open override val isOpenFlow: StateFlow<Boolean>

Whether if the endpoint is opened. For example, if the file is opened for FileSink.

open override val metrics: Any

Metrics of the sink.

open suspend override fun close()

Closes and releases resources

open override fun configure(config: SinkConfiguration)

Configure the Configurable implementation.

open suspend override fun open(mediaDescriptor: MediaDescriptor)

Opens the endpoint.

open suspend override fun openImpl(mediaDescriptor: MediaDescriptor)

Open an OutputStream to write data

open suspend override fun startStream()

Starts frames or data stream generation Throws an exception if not ready for live stream

open suspend override fun stopStream()

Stops frames or data stream generation

open suspend override fun write(packet: Packet): Int

Writes a buffer to the ISinkInternal.