Search before asking
Description
Give LimitBatchScanner and RecordBatchLogReader an into_stream() returning a Stream<Item = Result>, plus a bare-RecordBatch bridge for DataFusion/PyArrow (like the existing SyncRecordBatchLogReader). Additive - keep next_batch(). Do both readers together so the client gets one consistent stream surface.
Willingness to contribute
Search before asking
Description
Give LimitBatchScanner and RecordBatchLogReader an into_stream() returning a Stream<Item = Result>, plus a bare-RecordBatch bridge for DataFusion/PyArrow (like the existing SyncRecordBatchLogReader). Additive - keep next_batch(). Do both readers together so the client gets one consistent stream surface.
Willingness to contribute