Function arloader::update_bundle_statuses_stream

source · [−]

pub fn update_bundle_statuses_stream<'a, IP>(
    arweave: &'a Arweave, 
    paths_iter: IP, 
    buffer: usize
) -> impl Stream<Item = Result<BundleStatus, Error>> + 'a where
    IP: Iterator<Item = PathBuf> + Send + Sync + 'a,

Expand description

Queries network and updates locally stored BundleStatus structs.