Struct bitar::archive_reader::HttpReader

source ·
pub struct HttpReader { /* private fields */ }
Expand description

Read a http/https hosted archive.

Implementations§

source§

impl HttpReader

source

pub fn from_request(request_builder: RequestBuilder) -> Self

Create a remote archive reader using RequestBuilder for the http request.

source

pub fn from_url(url: Url) -> Self

Create a remote archive reader using an URL and default parameters for the request.

source

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.

source

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

§

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,

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>>

Read multiple chunks from archive. Returns a stream of the requested chunks.

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more