NSL WebSocket/xyz.noisif.nsl.websocket.broadcast/WsMessageSinkBroadcaster

WsMessageSinkBroadcaster

open class WsMessageSinkBroadcaster : WsBroadcaster

Constructors

WsMessageSinkBroadcaster

constructor(sink: WsMessageSink, serializer: EnvelopeSerializer<out Any>)

Properties

private val LOG: Logger

private val serializer: EnvelopeSerializer<out Any>

private val sink: WsMessageSink

Functions

open fun broadcast(op: OpCode)

open fun broadcast(topic: WsTopic, op: OpCode)

open fun broadcast(op: OpCode, payload: Any)

open fun broadcast(topic: WsTopic, op: OpCode, payload: Any)

open fun broadcastRaw(payload: String)

open fun broadcastRaw(topic: WsTopic, payload: String)

open fun broadcastRaw(payload: Array<Byte>)

open fun broadcastRaw(topic: WsTopic, payload: Array<Byte>)