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

Method onSendEvent

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

Source from the content-addressed store, hash-verified

118 }
119
120 public onSendEvent(event: Event): void {
121 this.subscriptions.forEach((filters, subscriptionId) => {
122 if (filters.map(isEventMatchingFilter).some((isMatch) => isMatch(event))) {
123 logger('sending event to client %s: %o', this.clientId, event)
124 this.sendMessage(createOutgoingEventMessage(subscriptionId, event))
125 }
126 })
127 }
128
129 private sendMessage(message: OutgoingMessage): void {
130 if (this.client.readyState !== WebSocket.OPEN) {

Callers

nothing calls this directly

Calls 2

sendMessageMethod · 0.95

Tested by

no test coverage detected