Struct bitar::archive_reader::HttpReader
source · pub struct HttpReader { /* private fields */ }
Expand description
Read a http/https hosted archive.
Implementations§
source§impl HttpReader
impl HttpReader
sourcepub fn from_request(request_builder: RequestBuilder) -> Self
pub fn from_request(request_builder: RequestBuilder) -> Self
Create a remote archive reader using RequestBuilder for the http request.
sourcepub fn from_url(url: Url) -> Self
pub fn from_url(url: Url) -> Self
Create a remote archive reader using an URL and default parameters for the request.
sourcepub fn retries(self, retry_count: u32) -> Self
pub fn retries(self, retry_count: u32) -> Self
Set number of times to retry on failure
The reader will try to reconnect and continue download from where the failure occurred. Any progress made so far should not be lost.
sourcepub fn retry_delay(self, retry_delay: Duration) -> Self
pub fn retry_delay(self, retry_delay: Duration) -> Self
Set a delay between attempts to reconnect to the remote server.
On failure the reader will wait for the given time before trying to reconnect.
Trait Implementations§
source§impl ArchiveReader for HttpReader
impl ArchiveReader for HttpReader
type Error = HttpReaderError
source§fn read_at<'life0, 'async_trait>(
&'life0 mut self,
offset: u64,
size: usize
) -> Pin<Box<dyn Future<Output = Result<Bytes, HttpReaderError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn read_at<'life0, 'async_trait>(
&'life0 mut self,
offset: u64,
size: usize
) -> Pin<Box<dyn Future<Output = Result<Bytes, HttpReaderError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Read a single chunk from archive.
source§fn read_chunks<'a>(
&'a mut self,
chunks: Vec<ChunkOffset>
) -> Pin<Box<dyn Stream<Item = Result<Bytes, HttpReaderError>> + Send + 'a>>
fn read_chunks<'a>( &'a mut self, chunks: Vec<ChunkOffset> ) -> Pin<Box<dyn Stream<Item = Result<Bytes, HttpReaderError>> + Send + 'a>>
Read multiple chunks from archive. Returns a stream of the requested chunks.
Auto Trait Implementations§
impl !Freeze for HttpReader
impl !RefUnwindSafe for HttpReader
impl Send for HttpReader
impl Sync for HttpReader
impl Unpin for HttpReader
impl !UnwindSafe for HttpReader
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more