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

Function subscribe

test-e2e/framework/record.ts:230–234  ·  view source on GitHub ↗
(clientExpression: string, recordName: string, immediate: boolean)

Source from the content-addressed store, hash-verified

228 },
229
230 subscribe (clientExpression: string, recordName: string, immediate: boolean) {
231 getRecordData(clientExpression, recordName).forEach((recordData) => {
232 recordData.record.subscribe(recordData.subscribeCallback, !!immediate)
233 })
234 },
235
236 unsubscribe (clientExpression: string, recordName: string) {
237 getRecordData(clientExpression, recordName).forEach((recordData) => {

Callers

nothing calls this directly

Calls 3

forEachMethod · 0.80
getRecordDataFunction · 0.70
subscribeMethod · 0.65

Tested by

no test coverage detected