MCPcopy Create free account
hub / github.com/Kilo-Org/cloud / subscribe

Method subscribe

packages/event-service/src/client.ts:271–285  ·  view source on GitHub ↗
(contexts: string[])

Source from the content-addressed store, hash-verified

269 }
270 });
271 });
272 }
273
274 private clearHandshakeTimer(): void {
275 if (this.handshakeTimer !== null) {
276 clearTimeout(this.handshakeTimer);
277 this.handshakeTimer = null;
278 }
279 }
280
281 disconnect(): void {
282 this.generation++;
283 this.destroyed = true;
284 if (this.reconnectTimer !== null) {
285 clearTimeout(this.reconnectTimer);
286 this.reconnectTimer = null;
287 }
288 this.clearHandshakeTimer();

Callers 15

usePresenceSubscriptionFunction · 0.80
client.test.tsFile · 0.80
subscribeToSessionFunction · 0.80
subscribeFunction · 0.80
store.test.tsFile · 0.80
subscribeToServiceStateFunction · 0.80
captureStatesFunction · 0.80
jotai.test.tsFile · 0.80
memory.test.tsFile · 0.80

Calls 5

isConnectedMethod · 0.95
sendMethod · 0.95
pushMethod · 0.80
getMethod · 0.65
setMethod · 0.65

Tested by 2

captureStatesFunction · 0.64