Struct HttpFetcher 

pub struct HttpFetcher { /* private fields */ }

Streams the package with reqwest, one chunk at a time.

The stream feature exists in this workspace for exactly this: the package is 150-300 MB, and nothing else should sit in memory while a connection may take minutes. Verifying it reads it in once, for seconds.

A connection that stops sending fails the download: every copy of the package on this host waits for it. There is no limit on the whole transfer, because a large package on a slow line is legitimately slow; only silence fails it, reqwest’s read timeout starting over with every read. What was written is removed by the caller, on every path out of the fetch, and it was never going to be taken for a package: an archive is only extracted once its digest matches.

Implementations

impl HttpFetcher

pub fn new(client: Client) -> Self

Trait Implementations

impl Clone for HttpFetcher

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpFetcher

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

Formats the value using the given formatter.

impl Default for HttpFetcher

fn default() -> Self

Returns the “default value” for a type.

impl PackageFetcher for HttpFetcher

fn fetch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, url: &'life1 str, destination: &'life2 Path, ) -> Pin<Box<dyn Future<Output = Result<u64, PackageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Stream url into destination, answering how many bytes were written.