Trait lance_core::utils::tracing::StreamTracingExt

pub trait StreamTracingExt {
    // Required method
    fn stream_in_current_span(self) -> InstrumentedStream<Self>
       where Self: Stream + Sized;
}

Required Methods

fn stream_in_current_span(self) -> InstrumentedStream<Self>

where Self: Stream + Sized,

All calls to poll the stream will be done in the context of the current span (when this method is called)

Implementors

impl<S: Stream> StreamTracingExt for S