krossbow-websocket-core/org.hildan.krossbow.websocket/UnboundedWsListenerFlowAdapter

UnboundedWsListenerFlowAdapter

class UnboundedWsListenerFlowAdapter(source)

An adapter similar to WebSocketListenerFlowAdapter, but with an unlimited buffer and non-suspending callback functions. This is useful for bridging implementations that do not support backpressure (like the browser WebSocket API).

This implementation does not support partial messages.

Constructors

constructor()

Properties

incomingFrames

val incomingFrames: Flow<WebSocketFrame>

The flow of incoming web socket frames. The underlying channel is closed when the web socket connection is closed

Functions

onBinaryMessage

fun onBinaryMessage(bytes: ByteString): ChannelResult<Unit>

Sends a WebSocketFrame.Binary frame to the incomingFrames flow.

onClose

fun onClose(code: Int, reason: String?): ChannelResult<Unit>

Sends a WebSocketFrame.Close to the incomingFrames flow, and completes it normally.

onError

fun onError(message: String)

Fails the incomingFrames flow with a WebSocketException with the given message.

fun onError(error: Throwable?)

Fails the incomingFrames flow with a WebSocketException with the given error as cause.

onPing

fun onPing(bytes: ByteString): ChannelResult<Unit>

Sends a WebSocketFrame.Ping frame to the incomingFrames flow.

onPong

fun onPong(bytes: ByteString): ChannelResult<Unit>

Sends a WebSocketFrame.Pong frame to the incomingFrames flow.

onTextMessage

fun onTextMessage(text: String): ChannelResult<Unit>

Sends a WebSocketFrame.Text frame to the incomingFrames flow.