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

Function subscribes

test-e2e/framework/event.ts:29–34  ·  view source on GitHub ↗
(clientExpression: string, subscriptionName: string)

Source from the content-addressed store, hash-verified

27 },
28
29 subscribes (clientExpression: string, subscriptionName: string) {
30 clientHandler.getClients(clientExpression).forEach((client) => {
31 client.event.callbacks[subscriptionName] = sinon.spy()
32 client.client.event.subscribe(subscriptionName, client.event.callbacks[subscriptionName])
33 })
34 },
35
36 unsubscribes (clientExpression: string, subscriptionName: string) {
37 clientHandler.getClients(clientExpression).forEach((client) => {

Callers

nothing calls this directly

Calls 2

forEachMethod · 0.80
subscribeMethod · 0.65

Tested by

no test coverage detected