Method send

packages/core/src/v3/zodIpc.ts:263–287

(
    type: K,
    payload: z.input<GetSocketMessageSchema<TEmitCatalog, K>>
  )

  }

  async send<K extends GetSocketMessagesWithoutCallback<TEmitCatalog>>(
    type: K,
    payload: z.input<GetSocketMessageSchema<TEmitCatalog, K>>
  ): Promise<void> {
    const schema = this.opts.emitSchema[type]["message"];

    if (!schema) {
      throw new Error(`Unknown message type: ${type as string}`);
    }

    const parsedPayload = schema.safeParse(payload);

    if (!parsedPayload.success) {
      throw new ZodSchemaParsedError(parsedPayload.error, payload);
    }

    await this.#sendPacket({
      type: "EVENT",
      message: {
        type,
        payload,
        version: "v1",
      },
    });
  }

  public async sendWithAck<K extends GetSocketMessagesWithCallback<TEmitCatalog>>(
    type: K,