deluge 0.2.1

A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible.
Documentation 
1
2
3
4
5
6
7
8
9
10

use crate::deluge::Deluge;

pub fn count<Del: Deluge>(deluge: Del) -> usize {
    let mut count = 0;
    while deluge.next().is_some() {
        count += 1;
    }

    count
}