Trait LogReaderExt

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

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

Object Safety

This trait is not object safe.

Implementors

impl<T> LogReaderExt for T

where T: LogReader,