Struct NotificationReceiver 

pub struct NotificationReceiver { /* private fields */ }

单消费者接收权，宿主可在不销毁旧 route 的情况下关闭并排空。

Implementations

impl NotificationReceiver

pub async fn recv(&mut self) -> Option<Envelope>

业务作用：取走一条已接受消息并从等待深度中扣除。

参数说明：无。

返回：消息或已关闭且排空的 None。

pub fn close(&mut self)

业务作用：关闭生产与接收入口，保留现有消息供有限排空。

参数说明：无。

返回：无；关闭后不再接受新通知。

pub fn discard_remaining(&mut self) -> usize

业务作用：在停机预算耗尽时计数并释放尚未投递的消息。

参数说明：无。

返回：本次放弃的消息数。

Trait Implementations

impl Drop for NotificationReceiver

fn drop(&mut self)

业务作用：异常退出也撤销旧路由并登记尚未消费的通知，避免悬空生产端。

参数说明：无。

返回：无；只进行有限队列清理和原子计数。

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.