Method _handleHSet

apps/realtime-server/src/sockets.ts:318–340

(args: [DataPrefix, string, string, any])

  }

  private async _handleHSet(args: [DataPrefix, string, string, any]) {
    const [prefix, suffix, field] = args;

    if (
      !(await (dataHashes[prefix] as DataHash)?.fields[field]?.userSettable?.({
        dataAbstraction: dataAbstraction(),
        userId: this.userId,
        suffix,
      }))
    ) {
      return;
    }

    const resolvable = new Resolvable();

    this._hSetBuffer.push([...args, resolvable]);

    if (this._hSetBuffer.length === 1) {
      setTimeout(() => this._flushHSetBuffer());
    }

    return await resolvable;
  }
  private async _flushHSetBuffer() {
    if (this._hSetBuffer.length === 0) {
      return;