Struct Channel 

pub struct Channel<T, const N: usize = async_flow::::tokio::channel::Channel::{constant#0}> {
    pub tx: Outputs<T, N>,
    pub rx: Inputs<T, N>,
}

Fields

tx: Outputs<T, N>

rx: Inputs<T, N>

Implementations

impl<T> Channel<T>

pub fn oneshot() -> Channel<T, async_flow::::tokio::channel::{impl#0}::oneshot::{constant#0}>

Creates a one-shot connection.

pub fn bounded( buffer: usize, ) -> Channel<T, async_flow::::tokio::channel::{impl#0}::bounded::{constant#0}>

Creates a bounded connection.

impl<T, const N: usize> Channel<T, N>

pub fn into_inner(self) -> (Outputs<T, N>, Inputs<T, N>)

Trait Implementations

impl<T, const N: usize> Debug for Channel<T, N>

where T: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<T, const N: usize> From<(Outputs<T, N>, Inputs<T, N>)> for Channel<T, N>

fn from(_: (Outputs<T, N>, Inputs<T, N>)) -> Channel<T, N>

Converts to this type from the input type.

impl<T, const N: usize> From<(Sender<PortEvent<T>>, Receiver<PortEvent<T>>)> for Channel<T, N>

fn from(_: (Sender<PortEvent<T>>, Receiver<PortEvent<T>>)) -> Channel<T, N>

Converts to this type from the input type.

impl<T> Connection<T> for Channel<T>