datum/io/mod.rs
1//! Streaming I/O — file sources and sinks, TCP, byte framing, and compression.
2//!
3//! This module provides Tokio-backed file and TCP I/O sources and sinks, delimiter- and
4//! length-field-based framing, gzip/deflate compression, and a [`StreamConverters`] bridge
5//! that adapts Tokio `AsyncRead`/`AsyncWrite` types to Datum streams.
6
7mod adapters;
8mod compression;
9mod framing;
10mod tokio_io;
11
12pub use adapters::{FileIO, InputStreamHandle, OutputStreamHandle, StreamConverters};
13pub use compression::Compression;
14pub use framing::{Framing, FramingByteOrder};
15pub use tokio_io::{
16 IoResult, TcpBinding, TcpConnection, TcpIncomingConnection, TokioByteSink, TokioByteSource,
17 TokioFileIO, TokioTcp,
18};