diff options
author | Ömer Sinan Ağacan <omeragacan@gmail.com> | 2019-11-28 19:54:50 +0300 |
---|---|---|
committer | Ivan Petkov <ivanppetkov@gmail.com> | 2019-11-28 08:54:50 -0800 |
commit | cd73951130286bc7c8ff113084e00a71eced4b60 (patch) | |
tree | 6b9df8f2f9406d53fb2b5ede28c3a0a2e4a85637 /tokio/src/signal | |
parent | 524e66314faacd9803792ce2a9dc13befd2ceeeb (diff) |
Implement Stream for signal::unix::Signal (#1849)
Refs #1848
Diffstat (limited to 'tokio/src/signal')
-rw-r--r-- | tokio/src/signal/unix.rs | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/tokio/src/signal/unix.rs b/tokio/src/signal/unix.rs index bb0afffe..b6ff9926 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<Option<()>> { + self.poll_recv(cx) + } + } +} + pub(crate) fn ctrl_c() -> io::Result<Signal> { signal(SignalKind::interrupt()) } |