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

Function run

Source 
pub(super) fn run(
    stream: Streaming<GetStreamResponse>,
    permits_tx: UnboundedSender<Value>,
    up_down_ids: UpDownActorIds,
    up_down_frag: UpDownFragmentIds,
    metrics: Arc<StreamingMetrics>,
    batched_permits_limit: usize,
) -> impl DispatcherMessageStream