rotor-stream 0.6.2

The stream abstration on top of rotor. This is the easiest way to build a protocol on top of TCP (Unix sockets) with rotor
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
29
30
31
32

use std::time::Duration;

use rotor::{Time, Response, GenericScope};


pub trait ResponseExt {
    fn deadline_opt(self, deadline: Option<Time>) -> Self;
}

impl<M, N> ResponseExt for Response<M, N> {
    fn deadline_opt(self, deadline: Option<Time>) -> Self {
        if let Some(time) = deadline {
            self.deadline(time)
        } else {
            self
        }
    }
}

pub trait ScopeExt {
    fn reached(&self, deadline: Option<Time>) -> bool;
    fn after(&self, milliseconds: u64) -> Time;
}

impl<T: GenericScope> ScopeExt for T {
    fn reached(&self, deadline: Option<Time>) -> bool {
        deadline.map(|x| self.now() >= x).unwrap_or(false)
    }
    fn after(&self, milliseconds: u64) -> Time {
        self.now() + Duration::from_millis(milliseconds)
    }
}