Function chain_inspection_streams 

fn chain_inspection_streams(
    streams: Vec<SendableRecordBatchStream>,
    schema: SchemaRef,
) -> Result<SendableRecordBatchStream>