Function arrow2::io::avro::read_async::block_stream

source · [−]

pub async fn block_stream<R: AsyncRead + Unpin + Send>(
    reader: &mut R, 
    file_marker: [u8; 16]
) -> impl Stream<Item = Result<CompressedBlock>> + '_

Available on crate features io_avro and io_avro_async only.

Expand description

Returns a fallible [Stream] of Avro blocks bound to reader