par-stream 0.5.0

Asynchronous parallel streams analogous to rayon
Documentation
pub use by_address::ByAddress;
pub use derivative::Derivative;
pub use futures::{
    stream::{FusedStream, Stream, StreamExt, TryStream, TryStreamExt},
    FutureExt,
};
pub use owning_ref::ArcRef;
pub use pin_project::pin_project;
pub use std::{
    cmp,
    cmp::Ordering,
    collections::HashMap,
    future::Future,
    iter,
    marker::PhantomData,
    mem::{self, ManuallyDrop},
    ops::{Deref, DerefMut},
    pin::Pin,
    ptr::{self, NonNull},
    slice,
    sync::{
        atomic::{AtomicUsize, Ordering::*},
        Arc, Weak,
    },
    task::{Context, Poll},
};