pub fn bounded_stream(
record_batch: RecordBatch,
limit: usize,
) -> SendableRecordBatchStreamExpand description
Creates a bounded stream that emits the same record batch a specified number of times. This is useful for testing purposes.
pub fn bounded_stream(
record_batch: RecordBatch,
limit: usize,
) -> SendableRecordBatchStreamCreates a bounded stream that emits the same record batch a specified number of times. This is useful for testing purposes.