Search before asking
Description
The bounded readers (RecordBatchLogReader, LimitBatchScanner) only expose next_batch().
Async consumers like DataFusion want a Stream.
An additive into_stream(self) -> impl Stream<Item = Result> on both, wrapping next_batch().
Willingness to contribute
Search before asking
Description
The bounded readers (RecordBatchLogReader, LimitBatchScanner) only expose next_batch().
Async consumers like DataFusion want a Stream.
An additive into_stream(self) -> impl Stream<Item = Result> on both, wrapping next_batch().
Willingness to contribute