MCPcopy Create free account
hub / github.com/TanStack/ai /

Class

packages/ai-opencode/src/stream/queue.ts:6–6  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

4 * the stream translator consumes.
5 */
6export class AsyncQueue<T> implements AsyncIterable<T> {
7 private readonly values: Array<T> = []
8 private readonly waiters: Array<{
9 resolve: (result: IteratorResult<T>) => void

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected