WebSocketReader

class WebSocketReader(byteChannel: ByteReadChannel, val coroutineContext: CoroutineContext, var maxFrameSize: Long, pool: ObjectPool<ByteBuffer> = KtorDefaultPool) : CoroutineScope

Class that continuously reads a byteChannel and converts into Websocket Frame exposing them in incoming.

Parameters

maxFrameSize

maximum frame size that could be read

Constructors

Link copied to clipboard
fun WebSocketReader(byteChannel: ByteReadChannel, coroutineContext: CoroutineContext, maxFrameSize: Long, pool: ObjectPool<ByteBuffer> = KtorDefaultPool)

Properties

Link copied to clipboard
Link copied to clipboard
val incoming: ReceiveChannel<Frame>

Channel receiving Websocket's Frame objects read from byteChannel.

Link copied to clipboard