diff --git a/broadcast/src/buffered/engine.rs b/broadcast/src/buffered/engine.rs index bb88a3b58e..e7db5366fd 100644 --- a/broadcast/src/buffered/engine.rs +++ b/broadcast/src/buffered/engine.rs @@ -447,8 +447,10 @@ impl 0 { + self.metrics + .subscribe + .inc_by(Status::Dropped, dropped_count as u64); } !waiters.is_empty() diff --git a/broadcast/src/buffered/ingress.rs b/broadcast/src/buffered/ingress.rs index a2b4ffb060..929a13ffc8 100644 --- a/broadcast/src/buffered/ingress.rs +++ b/broadcast/src/buffered/ingress.rs @@ -7,7 +7,7 @@ use futures::{ SinkExt, }; -/// Message types that can be sent to the `Mailbox` +/// Message types that can be sent to the [`Mailbox`] pub enum Message { /// Broadcast a [crate::Broadcaster::Message] to the network. ///