diff options
Diffstat (limited to 'tokio/src/time/timeout.rs')
-rw-r--r-- | tokio/src/time/timeout.rs | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/tokio/src/time/timeout.rs b/tokio/src/time/timeout.rs index 3a66a826..561dc0ca 100644 --- a/tokio/src/time/timeout.rs +++ b/tokio/src/time/timeout.rs @@ -107,9 +107,17 @@ pub struct Timeout<T> { } /// Error returned by `Timeout`. -#[derive(Debug)] +#[derive(Debug, PartialEq)] pub struct Elapsed(()); +impl Elapsed { + // Used on StreamExt::timeout + #[allow(unused)] + pub(crate) fn new() -> Self { + Elapsed(()) + } +} + impl<T> Timeout<T> { pub(crate) fn new_with_delay(value: T, delay: Delay) -> Timeout<T> { Timeout { value, delay } |