Method publish

apps/sim/lib/copilot/request/session/writer.ts:90–97

(event: StreamEvent)

  }

  publish(event: StreamEvent): void {
    const envelope = this.createEnvelope(event)
    this.enqueue(envelope)
    this.queuePersistence(envelope)
    if (event.type === MothershipStreamV1EventType.complete) {
      this._sawComplete = true
    }
  }

  markDisconnected(): void {
    this._clientDisconnected = true