Method _handleCommand

apps/realtime-server/src/sockets.ts:230–243

({ type, args }: RealtimeCommand)

    this.socket.send(encoding.toUint8Array(encoder));
  }
  private async _handleCommand({ type, args }: RealtimeCommand) {
    switch (type) {
      case RealtimeCommandType.HGET:
        return await this._handleHGet(args);
      case RealtimeCommandType.HSET:
        return await this._handleHSet(args);
      case RealtimeCommandType.SUBSCRIBE:
        return await this._handleSubscribe(args);
      case RealtimeCommandType.UNSUBSCRIBE:
        return await this._handleUnsubscribe(args);
      default:
        throw new Error('Unknown command type');
    }
  }

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