Function getMessageCount

packages/node-runtime/src/merger/temp-db.ts:271–273

()

      }))
    },
    getMessageCount(): number {
      return reader.getMessageCount()
    },
    streamMessages(batchSize: number, callback: (messages: MergerMessage[]) => void): void {
      reader.streamMessages(batchSize, (messages) => {
        callback(