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,
    database_id: DatabaseId,
    metrics: Arc<StreamingMetrics>,
    batched_permits_limit: usize,
    term_id: String,
) -> impl Stream<Item = Result<DispatcherMessage, StreamExecutorError>>