From 7ddd5a8190bbbf8092ef661abcdb046c479761d6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=96mer=20Sinan=20A=C4=9Facan?= Date: Thu, 28 Nov 2019 10:20:54 +0300 Subject: [PATCH] Implement Stream for signal::unix::Signal See #1848 --- tokio/src/signal/unix.rs | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/tokio/src/signal/unix.rs b/tokio/src/signal/unix.rs index bb0afffea73..b6ff9926eb2 100644 --- 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> { + self.poll_recv(cx) + } + } +} + pub(crate) fn ctrl_c() -> io::Result { signal(SignalKind::interrupt()) }