1
2
3
4
5
6
7
8
9
10
11
12
13
14

// Copyright 2019-2024 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}");
        }
    }
}