Method into_stream

datafusion/datasource/src/morsel/mocks.rs:632–642

(self: Box<Self>)

impl Morsel for MockMorsel {
    fn into_stream(self: Box<Self>) -> BoxStream<'static, Result<RecordBatch>> {
        self.observer.push(MorselEvent::MorselStreamStarted {
            morsel_id: self.morsel_id,
        });
        Box::pin(MockMorselStream {
            observer: self.observer.clone(),
            morsel_id: self.morsel_id,
            batch_ids: self.batch_ids.into(),
            finished: false,
        })
    }
}

/// Stream returned by [`MockMorsel::into_stream`].