Method into_stream

datafusion/datasource-parquet/src/push_decoder.rs:130–134

Drive the state machine to completion as a [`futures::Stream`] of record batches. The returned stream is fused and boxed so the caller can wrap it (for example, with an early-stopping adapter) without naming the unfold type.

(self)

    /// The returned stream is fused and boxed so the caller can wrap it (for
    /// example, with an early-stopping adapter) without naming the unfold type.
    pub(crate) fn into_stream(self) -> BoxStream<'static, Result<RecordBatch>> {
        futures::stream::unfold(self, |state| async move { state.transition().await })
            .fuse()
            .boxed()
    }

    /// Advances the decoder state machine until the next [`RecordBatch`] is
    /// produced, the file is fully consumed, or an error occurs.