Implement Stream for signal::unix::Signal (#1849)

Refs #1848
tokio-rs · Nov 28, 2019 · cd73951 · cd73951
1 parent 524e663
commit cd73951
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/tokio/src/signal/unix.rs b/tokio/src/signal/unix.rs
@@ -404,6 +404,16 @@ impl Signal {
     }
 }
 
+cfg_stream! {
+    impl futures_core::Stream for Signal {
+        type Item = ();
+
+        fn poll_next(mut self: std::pin::Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<()>> {
+            self.poll_recv(cx)
+        }
+    }
+}
+
 pub(crate) fn ctrl_c() -> io::Result<Signal> {
     signal(SignalKind::interrupt())
 }