Method poll_next

datafusion/datasource/src/file_stream/mod.rs:121–127

(
        mut self: Pin<&mut Self>,
        cx: &mut Context<'_>,
    )

    type Item = Result<RecordBatch>;

    fn poll_next(
        mut self: Pin<&mut Self>,
        cx: &mut Context<'_>,
    ) -> Poll<Option<Self::Item>> {
        let result = self.poll_inner(cx);
        self.baseline_metrics.record_poll(result)
    }
}

impl RecordBatchStream for FileStream {