risingwave_stream::executor::barrier_align

Function barrier_align

source 
pub fn barrier_align<'_async0>(
    left: BoxedMessageStream,
    right: BoxedMessageStream,
    actor_id: ActorId,
    fragment_id: FragmentId,
    metrics: Arc<StreamingMetrics>,
    executor_name: &'_async0 str,
) -> impl Stream<Item = Result<AlignedMessage, StreamExecutorError>> + '_async0