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

Function subscribe

test-e2e/framework/presence.ts:49–60  ·  view source on GitHub ↗
(clientExpression: string, user?: string)

Source from the content-addressed store, hash-verified

47export const presence = {
48 assert,
49 subscribe (clientExpression: string, user?: string) {
50 clientHandler.getClients(clientExpression).forEach((client) => {
51 if (!client.presence.callbacks[subscribeEvent]) {
52 client.presence.callbacks[subscribeEvent] = sinon.spy()
53 }
54 if (user) {
55 client.client.presence.subscribe(user, client.presence.callbacks[subscribeEvent])
56 } else {
57 client.client.presence.subscribe(client.presence.callbacks[subscribeEvent])
58 }
59 })
60 },
61
62 unsubscribe (clientExpression: string, user?: string) {
63 clientHandler.getClients(clientExpression).forEach((client) => {

Callers

nothing calls this directly

Calls 2

forEachMethod · 0.80
subscribeMethod · 0.65

Tested by

no test coverage detected