Struct Channel 

pub struct Channel<T, const N: usize = UNLIMITED> {
    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, ONESHOT>

Creates a one-shot connection.

pub fn bounded(buffer: usize) -> Channel<T, UNLIMITED>

Creates a bounded connection.

Examples found in repository

examples/basic.rs (line 6)

pub async fn main() {
    let (outputs, mut inputs) = async_flow::Channel::bounded(1).into_inner();

    tokio::spawn(async move {
        outputs.send("value1").await.unwrap();
        outputs.send("value2").await.unwrap();
    });

    while let Some(message) = inputs.recv().await.unwrap() {
        eprintln!("recv: {}", message);
    }
}

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

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

Examples found in repository

examples/basic.rs (line 6)

pub async fn main() {
    let (outputs, mut inputs) = async_flow::Channel::bounded(1).into_inner();

    tokio::spawn(async move {
        outputs.send("value1").await.unwrap();
        outputs.send("value2").await.unwrap();
    });

    while let Some(message) = inputs.recv().await.unwrap() {
        eprintln!("recv: {}", message);
    }
}

Trait Implementations

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

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

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((tx, rx): (Outputs<T, N>, Inputs<T, N>)) -> Self

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((tx, rx): (Sender<PortEvent<T>>, Receiver<PortEvent<T>>)) -> Self

Converts to this type from the input type.

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