risingwave_stream::executor::exchange::input::local_input

Function run_inner

source 
fn run_inner(
    channel: Receiver,
    upstream_actor_id: ActorId,
) -> impl Stream<Item = Result<DispatcherMessage, StreamExecutorError>>