Function make_cooperative

pub fn make_cooperative(
    stream: Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>,
) -> Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>

Wraps a SendableRecordBatchStream inside a CooperativeStream to enable cooperative multitasking. Since SendableRecordBatchStream is a dyn RecordBatchStream this requires the use of dynamic method dispatch. When the stream type is statically known, consider use the generic cooperative function to allow static method dispatch.