do not expect on unbounded send (#2530)

This commit is contained in:
Bernhard Schuster
2021-02-26 10:46:16 +01:00
committed by GitHub
parent 31327eb0c7
commit 05f74c2171
@@ -140,7 +140,7 @@ impl<T> UnboundedMeteredSender<T> {
/// Attempt to send message or fail immediately.
pub fn unbounded_send(&mut self, msg: T) -> result::Result<(), mpsc::TrySendError<T>> {
self.inner.unbounded_send(msg).expect("Unbounded send never fails. qed");
self.inner.unbounded_send(msg)?;
self.meter.fill.fetch_add(1, Ordering::SeqCst);
Ok(())
}