Trait lifeline::Channel

pub trait Channel {
    type Tx: Storage + Send + 'static;
    type Rx: Storage + Send + 'static;
    fn channel(capacity: usize) -> (Self::Tx, Self::Rx);
    fn default_capacity() -> usize;

    fn clone_tx(tx: &mut Option<Self::Tx>) -> Option<Self::Tx> { ... }
    fn clone_rx(
        rx: &mut Option<Self::Rx>, 
        _tx: Option<&Self::Tx>
    ) -> Option<Self::Rx> { ... }
}

Associated Types

type Tx: Storage + Send + 'static

type Rx: Storage + Send + 'static

Loading content...

Required methods

fn channel(capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

Loading content...

Provided methods

fn clone_tx(tx: &mut Option<Self::Tx>) -> Option<Self::Tx>

fn clone_rx(
    rx: &mut Option<Self::Rx>,
    _tx: Option<&Self::Tx>
) -> Option<Self::Rx>

Loading content...

Implementations on Foreign Types

impl<T: Send + 'static> Channel for Sender<T>

type Tx = Self

type Rx = Receiver<T>

fn channel(capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

impl<T: Send + 'static> Channel for Sender<T>

type Tx = Self

type Rx = Receiver<T>

fn channel(_capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

impl<T: Send + 'static> Channel for Sender<T>

type Tx = Self

type Rx = Receiver<T>

fn channel(capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

impl<T: Send + 'static> Channel for Sender<T>

type Tx = Self

type Rx = Receiver<T>

fn channel(capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

fn clone_rx(
    rx: &mut Option<Self::Rx>,
    tx: Option<&Self::Tx>
) -> Option<Self::Rx>

impl<T: Send + 'static> Channel for Sender<T>

type Tx = Self

type Rx = Receiver<T>

fn channel(_capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

impl<T> Channel for Sender<T> where
    T: Default + Clone + Send + Sync + 'static, 

type Tx = Self

type Rx = Receiver<T>

fn channel(_capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

Loading content...

Implementors

impl<T> Channel for lifeline::subscription::Sender<T> where
    T: Hash + Eq + Clone + Debug + Send + Sync + 'static, 

type Tx = Sender<T>

type Rx = Receiver<T>

fn channel(capacity: usize) -> (Self::Tx, Self::Rx)

fn default_capacity() -> usize

Loading content...