par-stream 0.10.2

Asynchronous parallel streams analogous to rayon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

pub use by_address::ByAddress;
pub use derivative::Derivative;
pub use futures::{
    future::{self, BoxFuture, Either, FutureExt as _},
    join, ready,
    sink::{Sink, SinkExt as _},
    stream::{self, BoxStream, FusedStream, Stream, StreamExt as _, TryStream, TryStreamExt as _},
};
pub use once_cell::sync::{Lazy, OnceCell};
pub use pin_project::pin_project;
pub use std::{
    borrow::Borrow,
    cell::UnsafeCell,
    cmp::{self, Ordering::*},
    collections::{hash_map, HashMap, VecDeque},
    fmt::{self, Debug, Display},
    future::Future,
    hash::{Hash, Hasher},
    iter,
    marker::{PhantomData, Sync},
    mem::{self, ManuallyDrop},
    ops::{ControlFlow, ControlFlow::*, Deref, DerefMut},
    pin::Pin,
    ptr::{self, NonNull},
    slice,
    sync::{
        atomic::{AtomicBool, AtomicUsize, Ordering::*},
        Arc, Weak,
    },
    task::{Context, Poll, Poll::*, Waker},
    time::Duration,
};

// pub type BoxSink<T, E> = Pin<Box<dyn Sink<T, Error = E> + Send>>;