fn merge(
inputs: Vec<BoxedMessageStream>,
metrics: Arc<StreamingMetrics>,
fragment_id: FragmentId,
actor_id: ActorId,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>Expand description
Merges input streams and aligns with barriers.