polars_arrow::io::ipc::read

Function into_flight_stream

Source 
pub async fn into_flight_stream<R: AsyncRead + AsyncSeek + Unpin + Send>(
    reader: &mut R,
) -> PolarsResult<impl Stream<Item = PolarsResult<EncodedData>> + '_>
Available on crate feature io_ipc only.