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.

Report a problem

Parameters

maxFrameSize

maximum frame size that could be read

Constructors

Link copied to clipboard
constructor(    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