Function deltalake::storage::object_store::collect_bytes

source · 
pub async fn collect_bytes<S, E>(
    stream: S,
    size_hint: Option<usize>
) -> Result<Bytes, E>
where
    E: Send,
    S: Stream<Item = Result<Bytes, E>> + Send + Unpin,
Expand description

Collect a stream into Bytes avoiding copying in the event of a single chunk