Module merge 

Modules

upstream 🔒

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.

MergeExecutorInner

The core of MergeExecutor and ReceiverExecutor.

MergeExecutorInput 🔒

Enums

MergeExecutorUpstream 🔒

Type Aliases

MergeExecutor

MergeExecutor merges data from multiple upstream actors and aligns them with barriers.

MergeUpstream

SelectReceivers

SingletonUpstream