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

Function queueClosedError

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

Source from the content-addressed store, hash-verified

162}
163
164function queueClosedError(): Error {
165 return new Error('cannot enqueue: async event queue is closed');
166}
167
168function consumerDetachedError(): Error {
169 return new Error('event consumer detached before the queue boundary was consumed');

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected