Struct ChannelSignal 

pub struct ChannelSignal { /* private fields */ }

自定义通道信号

通过 oneshot 通道接收停机信号

示例

use flare_core_runtime::signal::ChannelSignal;
use tokio::sync::oneshot;

let (tx, rx) = oneshot::channel();
let signal = ChannelSignal::new("custom", rx);

// 发送停机信号
tx.send(()).unwrap();

Implementations

impl ChannelSignal

pub fn new(name: impl Into<String>, rx: Receiver<()>) -> Self

创建新的通道信号

参数

• name - 信号名称
• rx - oneshot 接收器

Trait Implementations

impl ShutdownSignal for ChannelSignal

fn wait(&mut self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

等待信号触发

fn name(&self) -> &str

获取信号名称 (用于日志)