From 12be90e3fff4041ea6398fc8cd834c3ec173bce5 Mon Sep 17 00:00:00 2001
From: Juan Alvarez <j@yabit.io>
Date: Fri, 24 Jan 2020 17:22:56 -0600
Subject: stream: add StreamExt::timeout() (#2149)

---
 tokio/src/time/timeout.rs | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

(limited to 'tokio/src/time')

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 }
-- 
cgit v1.2.3