MCPcopy Create free account
hub / github.com/tiann/hapi / processQueue

Method processQueue

cli/src/claude/utils/OutgoingMessageQueue.ts:138–142  ·  view source on GitHub ↗

* Process queue - send messages in ID order that are released

()

Source from the content-addressed store, hash-verified

136 * Process queue - send messages in ID order that are released
137 */
138 private async processQueue(): Promise<void> {
139 await this.lock.inLock(async () => {
140 this.processQueueInternal();
141 });
142 }
143
144 /**
145 * Flush all messages immediately (for cleanup)

Callers 1

scheduleProcessingMethod · 0.95

Calls 2

processQueueInternalMethod · 0.95
inLockMethod · 0.80

Tested by

no test coverage detected