deluge 0.2.0

A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible.
Documentation 
use crate::deluge::Deluge;

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

    count
}