MCPcopy Create free account
hub / github.com/cameri/nostream / onBroadcast

Method onBroadcast

src/adapters/web-socket-adapter.ts:110–118  ·  view source on GitHub ↗
(event: Event)

Source from the content-addressed store, hash-verified

108 }
109
110 public onBroadcast(event: Event): void {
111 this.webSocketServer.emit(WebSocketServerAdapterEvent.Broadcast, event)
112 if (cluster.isWorker && typeof process.send === 'function') {
113 process.send({
114 eventName: WebSocketServerAdapterEvent.Broadcast,
115 event,
116 })
117 }
118 }
119
120 public onSendEvent(event: Event): void {
121 this.subscriptions.forEach((filters, subscriptionId) => {

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected