MCPcopy Index your code
hub / github.com/atomicdata-dev/atomic-data-browser / subscribe

Method subscribe

lib/src/store.ts:320–333  ·  view source on GitHub ↗
(subject: string, callback: callback)

Source from the content-addressed store, hash-verified

318 */
319 // TODO: consider subscribing to properties, maybe add a second subscribe function, use that in useValue
320 subscribe(subject: string, callback: callback): void {
321 if (subject == undefined) {
322 throw Error('Cannot subscribe to undefined subject');
323 return;
324 }
325 let callbackArray = this.subscribers.get(subject);
326 if (callbackArray == undefined) {
327 // Only subscribe once
328 this.subscribeWebSocket(subject);
329 callbackArray = [];
330 }
331 callbackArray.push(callback);
332 this.subscribers.set(subject, callbackArray);
333 }
334
335 subscribeWebSocket(subject: string): void {
336 if (subject == unknownSubject) {

Callers 2

useResourceFunction · 0.80
useResourcesFunction · 0.80

Calls 3

subscribeWebSocketMethod · 0.95
getMethod · 0.80
setMethod · 0.80

Tested by

no test coverage detected