1#![forbid(unsafe_code)]
2
3pub use futures;
4pub use std::cmp::Ordering;
5mod async_runtime;
6pub mod collect_and_apply;
7pub mod combinations;
8pub mod keep_first_n;
9pub mod marifold;
10pub mod multi_consumer_stream;
11pub mod permutations;
12pub mod run_stream;
13
14pub use collect_and_apply::CollectAndAppliable;
15pub use combinations::Combinable;
16pub use keep_first_n::KeepFirstN;
17pub use marifold::Marifold;
18pub use permutations::Permutable;
19
20pub use arrayvec;
21pub use futures::StreamExt;
22pub use gen_nested_iter_yield;
23pub use genawaiter;
24pub use once_cell;
25
26#[cfg(any(feature = "tokio", feature = "async-std"))]
27pub use num_cpus;
28
29#[cfg(feature = "io")]
30pub use async_compression;
31#[cfg(feature = "io")]
32pub use csv_async;
33#[cfg(feature = "io")]
34pub use flate2;
35#[cfg(feature = "io")]
36pub use serde;
37#[cfg(feature = "io")]
38pub use tokio;
39#[cfg(feature = "io")]
40pub use tokio::io::AsyncWriteExt;
41#[cfg(feature = "io")]
42pub use tokio_util;
43#[cfg(feature = "io")]
44pub use tokio_util::compat::TokioAsyncReadCompatExt;
45#[cfg(feature = "io")]
46pub use tokio_util::compat::TokioAsyncWriteCompatExt;
47#[cfg(feature = "io")]
48pub mod writer;