Method drainSandboxFileQueue

packages/ai/src/activities/chat/index.ts:2545–2550

* Drain queued `sandbox.file` chunks (emitted via the SandboxRuntime sink) * through the middleware pipeline and into the public stream.

()

   * through the middleware pipeline and into the public stream.
   */
  private async *drainSandboxFileQueue(): AsyncGenerator<StreamChunk> {
    while (this.sandboxFileQueue.length > 0) {
      const chunk = this.sandboxFileQueue.shift()
      if (chunk) yield* this.pipeThroughMiddleware(chunk)
    }
  }

  /**
   * Drain an executeToolCalls async generator, yielding any CustomEvent chunks