Function drain_batch_iterator 

pub fn drain_batch_iterator<T>(
    iterator: Arc<BatchIteratorProxy>,
) -> impl Stream<Item = Result<T, Error>>
where
    T: for<'a> Deserialize<'a> + Send + 'static,

Drain a batch iterator.