MCPcopy Index your code
hub / github.com/tiann/hapi / cleanup

Method cleanup

cli/src/utils/PushableAsyncIterable.ts:72–82  ·  view source on GitHub ↗

* Cleanup waiting consumers

()

Source from the content-addressed store, hash-verified

70 * Cleanup waiting consumers
71 */
72 private cleanup(): void {
73 // Resolve or reject all waiting consumers
74 while (this.waiters.length > 0) {
75 const waiter = this.waiters.shift()!
76 if (this.error) {
77 waiter.reject(this.error)
78 } else {
79 waiter.resolve({ done: true, value: undefined })
80 }
81 }
82 }
83
84 /**
85 * AsyncIterableIterator implementation

Callers 3

endMethod · 0.95
setErrorMethod · 0.95

Calls 2

rejectMethod · 0.80
resolveMethod · 0.80

Tested by

no test coverage detected