Skip to content

talkcontrol


talkcontrol / common/event-bus/websockets/event-bus-websockets-server / EventBusWebsocketsServer

Class: EventBusWebsocketsServer

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:10

Extends

Constructors

Constructor

new EventBusWebsocketsServer(server): EventBusWebsocketsServer

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:19

Parameters

server

Server

Returns

EventBusWebsocketsServer

Overrides

EventBus.constructor

Properties

callBacks

callBacks: Record<string, EventCallback[]> = {}

Defined in: src/common/event-bus/event-bus.ts:11

Inherited from

EventBus.callBacks


currentSessionId?

optional currentSessionId?: string

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:17


io

io: Server

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:12


sockets

sockets: Socket<DefaultEventsMap, DefaultEventsMap, DefaultEventsMap, any>[] = []

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:11

Methods

broadcast()

broadcast<K>(key, data?, broadcastToSockets?): void

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:85

Type Parameters

K

K extends string

Parameters

key

K

data?

PayloadFor<K>

broadcastToSockets?

boolean = true

Returns

void

Overrides

EventBus.broadcast


emitTo()

emitTo<K>(key, data, socket): void

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:99

Type Parameters

K

K extends string

Parameters

key

K

data

PayloadFor<K>

socket

Socket

Returns

void

Overrides

EventBus.emitTo


getCallbacks()

getCallbacks(key): EventCallback<unknown>[]

Defined in: src/common/event-bus/event-bus.ts:65

Parameters

key

string

Returns

EventCallback<unknown>[]

Inherited from

EventBus.getCallbacks


on()

on<K>(key, callback, socket?): void

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:76

Type Parameters

K

K extends string

Parameters

key

K

callback

EventCallback<PayloadFor<K>>

socket?

Socket<DefaultEventsMap, DefaultEventsMap, DefaultEventsMap, any>

Returns

void

Overrides

EventBus.on


onMultiple()

onMultiple<K>(key, callback, socket?): void

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:57

Type Parameters

K

K extends string

Parameters

key

K

callback

EventCallback<PayloadFor<K>> | null

socket?

Socket<DefaultEventsMap, DefaultEventsMap, DefaultEventsMap, any>

Returns

void

Overrides

EventBus.onMultiple


sessionMiddleware()

sessionMiddleware(socket, next): void

Defined in: src/common/event-bus/websockets/event-bus-websockets-server.ts:46

Parameters

socket

Socket

next

(err?) => void

Returns

void