MCPcopy Create free account
hub / github.com/ConsortiumAI/Consortium / enqueue

Method enqueue

packages/consortium-cli/src/claude/sdk/stream.ts:34–43  ·  view source on GitHub ↗
(value: T)

Source from the content-addressed store, hash-verified

32 }
33
34 enqueue(value: T): void {
35 if (this.readResolve) {
36 const resolve = this.readResolve
37 this.readResolve = undefined
38 this.readReject = undefined
39 resolve({ done: false, value })
40 } else {
41 this.queue.push(value)
42 }
43 }
44
45 done(): void {
46 this.isDone = true

Callers 1

readMessagesMethod · 0.80

Calls 1

pushMethod · 0.45

Tested by

no test coverage detected