bytefetch 0.2.0

A Rust library that makes HTTP file downloads easier to implement.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use std::sync::Arc;

use tokio::sync::Barrier;

use crate::http::bytes_aggregator::BytesAggregator;

pub(super) struct HttpDownloadSession {
    pub(super) aggregators: Vec<BytesAggregator>,
    pub(super) download_offsets: Vec<u64>,
    pub(super) barrier: Arc<Barrier>,
}

impl HttpDownloadSession {
    pub(super) fn new(tasks_count: usize) -> Self {
        Self {
            aggregators: vec![],
            download_offsets: vec![],
            barrier: Arc::new(Barrier::new(tasks_count)),
        }
    }

    pub(super) fn take_download_offsets(&mut self) -> Vec<u64> {
        std::mem::take(&mut self.download_offsets)
    }
}