StreamTracingExt

lance_core::utils::tracing

Trait StreamTracingExt 

Source 
pub trait StreamTracingExt {
    // Required methods
    fn stream_in_current_span(self) -> InstrumentedStream<Self>
       where Self: Stream + Sized;
    fn stream_in_span(self, span: Span) -> InstrumentedStream<Self>
       where Self: Stream + Sized;
}

Required Methods§

Source

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)

Source

fn stream_in_span(self, span: Span) -> InstrumentedStream<Self>
where Self: Stream + Sized,

Implementors§