lazyflow-io 0.7.0

I/O constructors for lazyflow -- TCP, UDP, and file convenience APIs
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

//! I/O constructors for `lazyflow` -- ergonomic sources and sinks for
//! files, TCP, and UDP.
//!
//! ```ignore
//! use lazyflow_io::net;
//!
//! net::tcp_server("0.0.0.0:8080".parse()?)
//!     .map(|conn| {
//!         let (lines, writer) = conn.into_lines();
//!         lines.eval_map(move |line| {
//!             let writer = writer.clone();
//!             async move {
//!                 writer.write_all(b"hello\n").await?;
//!                 Ok(line)
//!             }
//!         })
//!     })
//!     .par_join_unbounded()
//!     .for_each(|msg| println!("{msg}"))
//!     .await?;
//! ```

pub mod file;
pub mod net;