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