1 2 3 4 5 6 7 8 9 10 11 12 13 14
// Copyright 2019-2026 ChainSafe Systems // SPDX-License-Identifier: Apache-2.0, MIT pub trait FlumeSenderExt<T> { fn send_or_warn(&self, msg: T); } impl<T> FlumeSenderExt<T> for flume::Sender<T> { fn send_or_warn(&self, msg: T) { if let Err(e) = self.send(msg) { tracing::warn!("{e}"); } } }