Trait LogReaderExt

Source
pub trait LogReaderExt
where Self: LogReader,
{ // Required methods fn transform_chunk<F: Fn(StreamChunk) -> StreamChunk + Sized>( self, _: F, ) -> TransformChunkLogReader<F, Self>; fn monitored(self, _: LogReaderMetrics) -> impl LogReader; fn rate_limited(self, _: UnboundedReceiver<RateLimit>) -> impl LogReader; }

Required Methods§

Source

fn transform_chunk<F: Fn(StreamChunk) -> StreamChunk + Sized>( self, _: F, ) -> TransformChunkLogReader<F, Self>

Source

fn monitored(self, _: LogReaderMetrics) -> impl LogReader

Source

fn rate_limited(self, _: UnboundedReceiver<RateLimit>) -> impl LogReader

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<T> LogReaderExt for T
where T: LogReader,