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

Function run

source 
pub(super) fn run(
    channel: Receiver,
    upstream_actor_id: ActorId,
) -> impl DispatcherMessageStream