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