Module merge

Structs

BufferChunks 🔒

A wrapper that buffers the StreamChunks from upstream until no more ready items are available. Besides, any message other than StreamChunk will trigger the buffered StreamChunks to be emitted immediately along with the message itself.

MergeExecutor

MergeExecutor merges data from multiple channels. Dataflow from one channel will be stopped on barrier.

MergeExecutorInput 🔒

Enums

MergeExecutorUpstream 🔒

Type Aliases

SelectReceivers