Trait ChannelSend 

pub trait ChannelSend<T>: Send + Sync {
    // Required method
    fn send(&self, value: T) -> Backpressure;
}

Common sender interface.

use daedalus_core::channels::{bounded, ChannelSend, Backpressure};
let (tx, _rx) = bounded(1);
assert_eq!(tx.send(42), Backpressure::Ok);

Required Methods

fn send(&self, value: T) -> Backpressure

Implementors

impl<T: Send + Sync> ChannelSend<Arc<T>> for BroadcastSender<T>

impl<T: Send + Sync> ChannelSend<Arc<T>> for NewestSender<T>

impl<T: Send> ChannelSend<T> for BoundedSender<T>

impl<T: Send> ChannelSend<T> for UnboundedSender<T>