Enum RequestState 

enum RequestState<T> {
    None {
        input: T,
    },
    Outstanding {
        ranges: Vec<Range<u64>>,
        future: BoxFuture<'static, Result<(T, Vec<Bytes>)>>,
    },
    Done,
}

State machine that tracks outstanding requests to fetch data

The parameter T is the input, typically an AsyncFileReader

Variants

None

No outstanding requests

Fields

input: T

Outstanding

There is an outstanding request for data

Fields

ranges: Vec<Range<u64>>

Ranges that have been requested

future: BoxFuture<'static, Result<(T, Vec<Bytes>)>>

Future that will resolve (input, requested_ranges)

Note the future owns the reader while the request is outstanding and returns it upon completion

Done

Implementations

impl<T> RequestState<T>

where T: AsyncFileReader + Unpin + Send + 'static,

fn begin_request(input: T, ranges: Vec<Range<u64>>) -> Self

Issue a request to fetch ranges, returning the Outstanding state

Trait Implementations

impl<T> Debug for RequestState<T>

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

Formats the value using the given formatter.