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

Function sendAckMessage

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

* Sends a message based on the provided action and topic

(message: Message, allowBuffering: boolean = true)

Source from the content-addressed store, hash-verified

64 * Sends a message based on the provided action and topic
65 */
66 public sendAckMessage (message: Message, allowBuffering: boolean = true): void {
67 this.services.monitoring.onMessageSend(message)
68 this.sendBuiltMessage(this.getAckMessage(message), allowBuffering)
69 }
70
71 public abstract getMessage (message: Message): SerializedType
72 public abstract getAckMessage (message: Message): SerializedType

Callers

nothing calls this directly

Calls 3

sendBuiltMessageMethod · 0.80
onMessageSendMethod · 0.45
getAckMessageMethod · 0.45

Tested by

no test coverage detected