Type Alias MergeUpstream 

pub type MergeUpstream = BufferChunks<DynamicReceivers<ActorId, ()>>;

Aliased Type

pub struct MergeUpstream {
    inner: DynamicReceivers<TypedId<6>, ()>,
    chunk_builder: StreamChunkBuilder,
    pending_items: VecDeque<Result<MessageInner<()>, StreamExecutorError>>,
}

Fields

inner: DynamicReceivers<TypedId<6>, ()>

chunk_builder: StreamChunkBuilder

pending_items: VecDeque<Result<MessageInner<()>, StreamExecutorError>>

The items to be emitted. Whenever there’s something here, we should return a Poll::Ready immediately.