pub struct CtrlBreak { /* private fields */ }展开描述
代表一个监听器,用于接收通过 SetConsoleCtrlHandler
发递给进程的 “ctrl-break” 通知。
此监听器可以通过 CtrlBreakStream
转换为 Stream。
对进程的通知会通知所有监听该事件的接收者。 此外,如果通知没有被迟速处理,那么它们会被合并。 这意味着如果连续接收到两个通知, 则监听器只会收到一个包含这两个通知的项目。
实现§
Source§impl CtrlBreak
impl CtrlBreak
Sourcepub async fn recv(&mut self) -> Option<()>
pub async fn recv(&mut self) -> Option<()>
接收下一个信号通知事件。
虽然返回 Option<()>,但它仍然不会实际返回 None。
这是一个随机就暂开新的,去掉它会是个破坏性变更。
§示例
use tokio::signal::windows::ctrl_break;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
// A listener of CTRL-BREAK events.
let mut signal = ctrl_break()?;
// Print whenever a CTRL-BREAK event is received.
loop {
signal.recv().await;
println!("got signal CTRL-BREAK");
}
}Sourcepub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>>
pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>>
在 async 上下文中轮询接收下一个信号通知事件。
虽然返回 Option<()>,但它仍然不会实际返回 None。
这是一个随机就暂开新的,去掉它会是个破坏性变更。
§示例
从手动实现的 future 中轮询
use std::pin::Pin;
use std::future::Future;
use std::task::{Context, Poll};
use tokio::signal::windows::CtrlBreak;
struct MyFuture {
ctrl_break: CtrlBreak,
}
impl Future for MyFuture {
type Output = Option<()>;
fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
println!("polling MyFuture");
self.ctrl_break.poll_recv(cx)
}
}Trait 实现§
自动 Trait 实现§
impl Freeze for CtrlBreak
impl !RefUnwindSafe for CtrlBreak
impl Send for CtrlBreak
impl Sync for CtrlBreak
impl Unpin for CtrlBreak
impl UnsafeUnpin for CtrlBreak
impl !UnwindSafe for CtrlBreak
Blanket 实现§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. 更多信息