MCPcopy Create free account
hub / github.com/subquery/subql / on

Method on

packages/node-core/src/utils/queues/autoQueue.ts:217–221  ·  view source on GitHub ↗
(evt: 'size', callback: (size: number) => void | Promise<void>)

Source from the content-addressed store, hash-verified

215 }
216
217 on(evt: 'size', callback: (size: number) => void | Promise<void>): () => void {
218 this.eventEmitter.on(evt, callback as (size: number) => void);
219
220 return () => this.eventEmitter.off(evt, callback as (size: number) => void);
221 }
222
223 async onIdle(): Promise<void> {
224 if (this.size === 0) {

Callers 8

getRecordsWithEntriesMethod · 0.45
registerPgListenerMethod · 0.45
sandbox.spec.tsFile · 0.45
constructorMethod · 0.45
constructorFunction · 0.45
constructorMethod · 0.45
worker.tsFile · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected