MCPcopy
hub / github.com/deepstreamIO/deepstream.io / sendMessage

Function sendMessage

src/connection-endpoint/base/socket-wrapper.ts:58–61  ·  view source on GitHub ↗

* Sends a message based on the provided action and topic

(message: { topic: TOPIC, action: CONNECTION_ACTION } | Message, allowBuffering: boolean = true)

Source from the content-addressed store, hash-verified

56 * Sends a message based on the provided action and topic
57 */
58 public sendMessage (message: { topic: TOPIC, action: CONNECTION_ACTION } | Message, allowBuffering: boolean = true): void {
59 this.services.monitoring.onMessageSend(message)
60 this.sendBuiltMessage(this.getMessage(message), allowBuffering)
61 }
62
63 /**
64 * Sends a message based on the provided action and topic

Callers

nothing calls this directly

Calls 3

sendBuiltMessageMethod · 0.80
onMessageSendMethod · 0.45
getMessageMethod · 0.45

Tested by

no test coverage detected