lightstream 0.4.4

Composable, zero-copy Arrow IPC and native data streaming for Rust with SIMD-aligned I/O, async support, and memory-mapping.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12

//! # Asynchronous QUIC byte stream
//!
//! Type alias over [`AsyncReadByteStream`] for QUIC receive streams.
//!
//! ## Use cases
//! - Receive Arrow IPC streams over QUIC without loading them fully into memory.
//! - Feed QUIC I/O directly into async Arrow decoding pipelines.

use crate::models::streams::async_read::AsyncReadByteStream;

/// A `Stream` that reads a QUIC receive stream in fixed-size byte chunks.
pub type QuicByteStream = AsyncReadByteStream<quinn::RecvStream>;