MCPcopy Index your code
hub / github.com/cameri/nostream / onSubscribed

Method onSubscribed

src/adapters/web-socket-adapter.ts:105–108  ·  view source on GitHub ↗
(subscriptionId: string, filters: SubscriptionFilter[])

Source from the content-addressed store, hash-verified

103 }
104
105 public onSubscribed(subscriptionId: string, filters: SubscriptionFilter[]): void {
106 logger('client %s subscribed %s to %o', this.clientId, subscriptionId, filters)
107 this.subscriptions.set(subscriptionId, filters)
108 }
109
110 public onBroadcast(event: Event): void {
111 this.webSocketServer.emit(WebSocketServerAdapterEvent.Broadcast, event)

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected