stream: add StreamExt::timeout() (#2149)

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 }