Method streamMessages

packages/node-runtime/src/merger/index.ts:40–40 · view source on GitHub ↗

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

Source from the content-addressed store, hash-verified

38	getMembers(): MergerMember[]
39	getMessageCount(): number
40	streamMessages(batchSize: number, callback: (messages: MergerMessage[]) => void): void
41	}
42
43	// ==================== Output types ====================

checkConflictsFromSourcesFunction · 0.65

buildMergedOutputFunction · 0.65

streamMessagesFunction · 0.65

TempDbReaderpackages/node-runtime/src/merger/temp-

no outgoing calls

no test coverage detected