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
pub mod all;
#[cfg(feature = "async-runtime")]
pub mod all_par;
pub mod any;
#[cfg(feature = "async-runtime")]
pub mod any_par;
pub mod chain;
pub mod collect;
#[cfg(feature = "async-runtime")]
pub mod collect_par;
pub mod count;
//pub mod filter;
pub mod filter_map;
pub mod first;
pub mod fold;
#[cfg(feature = "async-runtime")]
pub mod fold_par;
pub mod last;
pub mod map;
pub mod take;
#[cfg(feature = "async-runtime")]
pub mod zip;

pub(crate) use all::*;
#[cfg(feature = "async-runtime")]
pub(crate) use all_par::*;
pub(crate) use any::*;
#[cfg(feature = "async-runtime")]
pub(crate) use any_par::*;
pub(crate) use chain::*;
pub(crate) use collect::*;
#[cfg(feature = "async-runtime")]
pub(crate) use collect_par::*;
pub(crate) use count::*;
//pub(crate) use filter::*;
pub(crate) use filter_map::*;
pub(crate) use first::*;
pub(crate) use fold::*;
#[cfg(feature = "async-runtime")]
pub(crate) use fold_par::*;
pub(crate) use last::*;
pub(crate) use map::*;
pub(crate) use take::*;
#[cfg(feature = "async-runtime")]
pub(crate) use zip::*;