Function count_elems 

pub fn count_elems<'a, T: 'a>(
    process: &Process<'a>,
    input_stream: Stream<T, Process<'a>, Unbounded>,
) -> Stream<u32, Process<'a>, Unbounded>