Function timeout 

pub fn timeout<T>(
    s: RS2Stream<T>,
    duration: Duration,
) -> RS2Stream<StreamResult<T>>
where
    T: Send + 'static,

Add timeout support to any rs2_stream