WebSocketWriter

class WebSocketWriter(writeChannel: ByteWriteChannel, val coroutineContext: CoroutineContext, var masking: Boolean = false, val pool: ObjectPool<ByteBuffer> = KtorDefaultPool, queueConfig: ChannelConfig = ChannelConfig.UNLIMITED) : CoroutineScope(source)

Class that processes written outgoing Websocket Frame, serializes them, and writes the bits into the writeChannel.

queueConfig

: configuration for the internal Frame queue.

Constructors

constructor(writeChannel: ByteWriteChannel, coroutineContext: CoroutineContext, masking: Boolean = false, pool: ObjectPool<ByteBuffer> = KtorDefaultPool, queueConfig: ChannelConfig = ChannelConfig.UNLIMITED)

: whether it will mask serialized frames.

Channel for sending Websocket's Frame that will be serialized and written to writeChannel.

: ByteBuffer pool to be used by this writer

suspend fun flush()

Ensures all enqueued messages have been written

suspend fun send(frame: Frame)

Send a frame and write it and all outstanding frames in the queue