Function decode_batch_stream 

pub fn decode_batch_stream<T: Send + 'static>(
    record_batch_stream: SendableRecordBatchStream,
    decode: fn(RecordBatch) -> Vec<T>,
) -> BoxStream<'static, Result<T>>

Decode a record batch stream to a stream of items.