Function spawn_buffered 

pub fn spawn_buffered(
    input: SendableRecordBatchStream,
    buffer: usize,
) -> SendableRecordBatchStream

If running in a tokio context spawns the execution of stream to a separate task allowing it to execute in parallel with an intermediate buffer of size buffer