Function wakeQueuedSubscriber

packages/ai-client/tests/chat-client.test.ts:542–546

()

      let staleReleased = false
      let wakeSubscriber: (() => void) | null = null
      const wakeQueuedSubscriber = () => {
        const wake = wakeSubscriber
        wakeSubscriber = null
        wake?.()
      }
      const adapter: ConnectionAdapter = {
        subscribe: vi.fn(
          (_signal?: AbortSignal): AsyncIterable<StreamChunk> => {