Method getMeta

packages/node-runtime/src/merger/index.ts:37–37

()

 */
export interface MergerDataSource {
  getMeta(): MergerSourceMeta | null
  getMembers(): MergerMember[]
  getMessageCount(): number
  streamMessages(batchSize: number, callback: (messages: MergerMessage[]) => void): void