Struct HttpByteSource 

pub struct HttpByteSource { /* private fields */ }

Random-access COPC byte source backed by HTTP range requests.

Implementations

impl HttpByteSource

pub fn new(url: impl Into<String>) -> Result<HttpByteSource, IoError>

Creates an HTTP byte source for a remote COPC URL.

pub fn with_max_parallel_ranges( self, max_parallel_ranges: usize, ) -> HttpByteSource

Limits how many HTTP range requests are in flight at once.

pub fn url(&self) -> &str

Returns the source URL.

pub fn max_parallel_ranges(&self) -> usize

Returns the configured maximum number of parallel range requests.

Trait Implementations

impl ByteSource for HttpByteSource

async fn read_range( &self, offset: u64, length: u64, ) -> Result<Vec<u8>, CopcError>

Read length bytes starting at offset.

async fn read_ranges( &self, ranges: &[(u64, u64)], ) -> Result<Vec<Vec<u8>>, CopcError>

Read multiple ranges in one logical operation.

async fn size(&self) -> Result<Option<u64>, CopcError>

Total size of the source in bytes, if known.

impl Clone for HttpByteSource

fn clone(&self) -> HttpByteSource

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HttpByteSource

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

Formats the value using the given formatter.

impl PartialEq for HttpByteSource

fn eq(&self, other: &HttpByteSource) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for HttpByteSource

impl StructuralPartialEq for HttpByteSource