Expand description
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.
Structs§
- Compression
- FileIO
- Framing
- Input
Stream Handle - A blocking
std::io::Readhandle materialized byStreamConverters::as_input_stream. - IoResult
- Akka-style materialized IO result for Tokio-backed file and TCP byte streams.
- Output
Stream Handle - A blocking
std::io::Writehandle materialized byStreamConverters::as_output_stream. - Stream
Converters - TcpBinding
- TcpConnection
- TcpIncoming
Connection - A TCP connection accepted by
TokioTcp::bind. - Tokio
FileIO - Tokio
Tcp