Class FakeWebSocket

packages/ai-acp/tests/transport.test.ts:11–22

import type { SandboxCapabilities, SpawnHandle } from '@tanstack/ai-sandbox'

class FakeWebSocket extends EventTarget {
  sent: Array<string> = []
  send(data: string): void {
    this.sent.push(data)
  }
  close(): void {}
  emitMessage(data: string): void {
    const event = new Event('message') as Event & { data: string }
    event.data = data
    this.dispatchEvent(event)
  }
}

async function* once(value: string): AsyncIterable<string> {
  await Promise.resolve()