Function arrow2::io::parquet::read::_get_page_stream

pub async fn _get_page_stream<RR>(
    column_metadata: &'a ColumnChunkMetaData, 
    reader: &'a mut RR, 
    buffer: Vec<u8, Global>, 
    pages_filter: Arc<dyn Fn(&Descriptor, &DataPageHeader) + Sync + Send + 'static>
) -> Result<impl Stream<Item = Result<CompressedDataPage, Error>> + 'a, Error> where
    RR: AsyncRead + Unpin + Send + AsyncSeek, 

Available on crate feature io_parquet only.

Returns a stream of compressed data pages