Method _subscribe

apps/client/src/code/realtime/context.ts:101–126

(prefix: DataPrefix, suffix: string, field: string)

      }

      private _subscribe(prefix: DataPrefix, suffix: string, field: string) {
        const fullKey = getFullKey(prefix, suffix, field);

        if (this.subscriptions.has(fullKey)) {
          return;
        }

        this._logger.sub('subscribe').info(fullKey);

        this.subscriptions.add(fullKey);

        if (!internals.realtime.isSynced(prefix as any, suffix, field)) {
          internals.realtime.pending.set(fullKey, new Resolvable());
          this.pending.add(fullKey);
        }

        internals.realtime.subscriptions[fullKey] ??= new Set();
        internals.realtime.subscriptions[fullKey].add(this);

        if (internals.realtime.subscriptions[fullKey].size === 1) {
          internals.realtime.pushCommand({
            type: RealtimeCommandType.SUBSCRIBE,
            args: [prefix, suffix, field],
          });
        }
      }
      unsubscribe(prefix: DataPrefix, suffix: string, field: string) {
        const fullKey = getFullKey(prefix, suffix, field);