Function streamMessages

packages/node-runtime/src/merger/temp-db.ts:274–287

(batchSize: number, callback: (messages: MergerMessage[]) => void)

      return reader.getMessageCount()
    },
    streamMessages(batchSize: number, callback: (messages: MergerMessage[]) => void): void {
      reader.streamMessages(batchSize, (messages) => {
        callback(
          messages.map((msg) => ({
            senderPlatformId: msg.senderPlatformId,
            senderAccountName: msg.senderAccountName,
            senderGroupNickname: msg.senderGroupNickname,
            timestamp: msg.timestamp,
            type: msg.type,
            content: msg.content,
          }))
        )
      })
    },
  }
}