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

Function run_inner

source 
fn run_inner(
    client_pool: ComputeClientPool,
    upstream_addr: HostAddr,
    up_down_ids: UpDownActorIds,
    up_down_frag: UpDownFragmentIds,
    metrics: Arc<StreamingMetrics>,
    batched_permits_limit: usize,
) -> impl Stream<Item = Result<DispatcherMessage, StreamExecutorError>>