Struct BufferScheduler 

pub struct BufferScheduler { /* private fields */ }

An implementation of EncodingsIo that serves data from an in-memory buffer

Implementations

impl BufferScheduler

pub fn new(data: Bytes) -> Self

Trait Implementations

impl Debug for BufferScheduler

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

Formats the value using the given formatter.

impl EncodingsIo for BufferScheduler

fn submit_request( &self, ranges: Vec<Range<u64>>, _priority: u64, ) -> BoxFuture<'static, Result<Vec<Bytes>>>

Submit an I/O request

fn submit_single( &self, range: Range<u64>, priority: u64, ) -> BoxFuture<'static, Result<Bytes>>

Submit an I/O request with a single range

fn with_bypass_backpressure(&self) -> Option<Arc<dyn EncodingsIo>>

Returns a version of this I/O service that bypasses backpressure for all requests.