FusedStream for IpcStream

Implements `FusedStream` trait for `IpcStream`, so allow the usage of the `select!` macro: https://docs.rs/futures/0.3.18/futures/stream/trait.FusedStream.html
servo · Dec 9, 2021 · 5582ad5 · 5582ad5
1 parent f700ea3
commit 5582ad5
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/asynch.rs b/src/asynch.rs
@@ -112,3 +112,12 @@ where
         }
     }
 }
+
+impl<T> FusedStream for IpcStream<T> 
+where
+    T: for<'de> Deserialize<'de> + Serialize,
+{
+    fn is_terminated(&self) -> bool {
+        self.0.is_terminated()
+    }
+}