datum-core 0.7.0

Rust stream-processing library mirroring Akka/Pekko Streams Typed, built on Ractor actors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Streaming I/O — file sources and sinks, TCP, byte framing, and compression.
//!
//! This module provides Tokio-backed file and TCP I/O sources and sinks, delimiter- and
//! length-field-based framing, gzip/deflate compression, and a [`StreamConverters`] bridge
//! that adapts Tokio `AsyncRead`/`AsyncWrite` types to Datum streams.

mod adapters;
mod compression;
mod framing;
mod tokio_io;

pub use adapters::{FileIO, InputStreamHandle, OutputStreamHandle, StreamConverters};
pub use compression::Compression;
pub use framing::{Framing, FramingByteOrder};
#[cfg(feature = "io-uring-file")]
pub use tokio_io::UringFileIO;
pub use tokio_io::{
    IoResult, TcpBinding, TcpConnection, TcpIncomingConnection, TokioByteSink, TokioByteSource,
    TokioFileIO, TokioTcp,
};