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

Method wake

packages/runtime/src/async-queue.ts:113–118  ·  view source on GitHub ↗

Wake all progress waiters so they re-check their condition.

()

Source from the content-addressed store, hash-verified

111
112 /** Wake all progress waiters so they re-check their condition. */
113 wake(): void {
114 if (this.progressWaiters.length === 0) return;
115 const waiters = this.progressWaiters;
116 this.progressWaiters = [];
117 for (const resolve of waiters) resolve();
118 }
119
120 close(): void {
121 if (this.closed) return;

Callers 7

sendWithinScopeMethod · 0.95
enqueueMethod · 0.95
ackConsumedMethod · 0.95
noteConsumerDetachedMethod · 0.95
closeMethod · 0.95
errorMethod · 0.95

Calls 1

resolveFunction · 0.70

Tested by

no test coverage detected