Method push

packages/web/src/clients/websocket/channel.ts:109–123

(event: K, payload: z.TypeOf<O[K]>)

  }

  push<K extends keyof O & string>(event: K, payload: z.TypeOf<O[K]>): void {
    // Queue outgoing events until we are subscribed.
    if (!this.subscribed) {
      this.queue.push({ event, payload });
      return;
    }

    const schema = this.events.outgoing[event];

    if (schema === undefined) {
      throw new Error(`Cannot push unknown event '${event}' for topic '${this.topic}'`);
    }

    this.client.push(this.topic, event, schema.parse(payload));
  }

  private receiveSubscribedEvent(payload: { id: string }) {
    // This shouldn't normally happen, but could if multiple channels for the