Struct CacheMergePusher 

pub struct CacheMergePusher<P> { /* private fields */ }

优先选择大块调用 push，并且会把大块合并成一个 Bytes

Implementations

impl<P> CacheMergePusher<P>

where P: Pusher,

pub const fn new( inner: P, high_watermark: usize, low_watermark: usize, ) -> CacheMergePusher<P>

Trait Implementations

impl<P> Debug for CacheMergePusher<P>

where P: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<P> Pusher for CacheMergePusher<P>

where P: Pusher,

type Error = <P as Pusher>::Error

fn push( &mut self, range: &Range<u64>, bytes: Bytes, ) -> Result<(), (<CacheMergePusher<P> as Pusher>::Error, Bytes)>

fn flush(&mut self) -> Result<(), <CacheMergePusher<P> as Pusher>::Error>