dlmgr 0.3.1

A multi-threaded file downloader.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use async_trait::async_trait;

#[async_trait]
pub trait SequentialChunkConsumer: Send + Sync {
    async fn consume_bytes(&mut self, chunk: Vec<u8>) -> Result<(), anyhow::Error>;

    async fn finalise(self: Box<Self>);

    async fn on_failure(self: Box<Self>);
}

impl<T> From<T> for Box<dyn SequentialChunkConsumer>
where
    T: SequentialChunkConsumer + 'static,
{
    fn from(value: T) -> Self
    where
        T: SequentialChunkConsumer + 'static,
    {
        Box::new(value)
    }
}