NSL WebSocket/xyz.noisif.nsl.websocket.dispatcher/ConcurrentLocalSessionDispatcher

ConcurrentLocalSessionDispatcher

open class ConcurrentLocalSessionDispatcher : LocalSessionDispatcher

Constructors

ConcurrentLocalSessionDispatcher

private constructor(registry: WsSessionRegistry, executorService: ExecutorService)

Properties

executorService

private val executorService: ExecutorService

private val LOG: Logger

private val registry: WsSessionRegistry

Functions

private open fun broadcast(sessions: Collection<WsSession>, topic: String, payload: Array<Byte>)

open fun createVirtual(registry: WsSessionRegistry): ConcurrentLocalSessionDispatcher

open fun dispatchRaw(topic: String, payload: Array<Byte>)

open fun dispatchRawAll(payload: Array<Byte>)

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

open fun payloadAll(payload: Array<Byte>)

private open fun send(session: WsSession, payload: Array<Byte>)