| 1 | // Copyright 2016 Amanieu d'Antras |
| 2 | // |
| 3 | // Licensed under the Apache License, Version 2.0, <LICENSE-APACHE or |
| 4 | // http://apache.org/licenses/LICENSE-2.0> or the MIT license <LICENSE-MIT or |
| 5 | // http://opensource.org/licenses/MIT>, at your option. This file may not be |
| 6 | // copied, modified, or distributed except according to those terms. |
| 7 | |
| 8 | use std::time::{Duration, Instant}; |
| 9 | |
| 10 | // Option::unchecked_unwrap |
| 11 | pub trait UncheckedOptionExt<T> { |
| 12 | unsafe fn unchecked_unwrap(self) -> T; |
| 13 | } |
| 14 | |
| 15 | impl<T> UncheckedOptionExt<T> for Option<T> { |
| 16 | #[inline ] |
| 17 | unsafe fn unchecked_unwrap(self) -> T { |
| 18 | match self { |
| 19 | Some(x: T) => x, |
| 20 | None => unreachable(), |
| 21 | } |
| 22 | } |
| 23 | } |
| 24 | |
| 25 | // hint::unreachable_unchecked() in release mode |
| 26 | #[inline ] |
| 27 | unsafe fn unreachable() -> ! { |
| 28 | if cfg!(debug_assertions) { |
| 29 | unreachable!(); |
| 30 | } else { |
| 31 | core::hint::unreachable_unchecked() |
| 32 | } |
| 33 | } |
| 34 | |
| 35 | #[inline ] |
| 36 | pub fn to_deadline(timeout: Duration) -> Option<Instant> { |
| 37 | Instant::now().checked_add(duration:timeout) |
| 38 | } |
| 39 | |