MCPcopy Create free account
hub / github.com/apache/maka / canEnqueue

Method canEnqueue

packages/runtime/src/async-queue.ts:68–70  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

66 }
67
68 private canEnqueue(): boolean {
69 return !this.closed && !this.err && !this.consumerDetached;
70 }
71
72 private enqueue(item: T): number {
73 const sequence = ++this.pushedCount;

Callers 1

pushMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected