fast-pull 4.0.2

Pull everything fast
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
26
27
28

use crate::ProgressEntry;
use bytes::Bytes;
use core::time::Duration;
use futures::TryStream;

pub trait PullStream<E>:
    TryStream<Ok = Bytes, Error = (E, Option<Duration>)> + Send + Unpin
{
}
impl<E, T> PullStream<E> for T where
    T: TryStream<Ok = Bytes, Error = (E, Option<Duration>)> + Send + Unpin
{
}
pub type PullResult<T, E> = Result<T, (E, Option<Duration>)>;

pub trait Puller: Send + Sync + Clone + 'static {
    type Error: PullerError;
    fn pull(
        &mut self,
        range: Option<&ProgressEntry>,
    ) -> impl Future<Output = PullResult<impl PullStream<Self::Error>, Self::Error>> + Send;
}

pub trait PullerError: Send + Unpin + 'static {
    fn is_irrecoverable(&self) -> bool {
        false
    }
}