Function hydro_test_local::local::count_elems::count_elems_generic
source ยท pub fn count_elems_generic<'a, T: 'a>(
flow: FlowBuilder<'a>,
input_stream: RuntimeData<UnboundedReceiverStream<T>>,
output: RuntimeData<&'a UnboundedSender<u32>>,
) -> impl Quoted<'a, Dfir<'a>>