risingwave_stream::executor::exchange::input::remote_input

Function run

source 
pub(super) fn run(
    client_pool: ComputeClientPool,
    upstream_addr: HostAddr,
    up_down_ids: UpDownActorIds,
    up_down_frag: UpDownFragmentIds,
    metrics: Arc<StreamingMetrics>,
    batched_permits_limit: usize,
) -> impl DispatcherMessageStream