Struct Outputs 

pub struct Outputs<T, const N: usize = 0> { /* private fields */ }

Implementations

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

pub fn is_open(&self) -> bool

pub fn is_closed(&self) -> bool

pub fn capacity(&self) -> Option<usize>

pub fn max_capacity(&self) -> Option<usize>

pub fn close(&mut self)

pub async fn send(&self, value: T) -> Result<(), SendError>

Examples found in repository

examples/sqrt.rs (line 20)

async fn sqrt(mut inputs: Inputs<f64>, outputs: Outputs<f64>) -> Result {
    while let Some(input) = inputs.recv().await? {
        let output = input.sqrt();
        outputs.send(output).await?;
    }
    Ok(())
}

examples/basic.rs (line 9)

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);
    }
}

pub fn send_blocking(&self, value: T) -> Result<(), SendError>

Trait Implementations

impl<T, const N: usize> AsMut<Sender<T>> for Outputs<T, N>

fn as_mut(&mut self) -> &mut Sender<T>

Converts this type into a mutable reference of the (usually inferred) input type.

impl<T, const N: usize> AsRef<Sender<T>> for Outputs<T, N>

fn as_ref(&self) -> &Sender<T>

Converts this type into a shared reference of the (usually inferred) input type.

impl<T: Clone, const N: usize> Clone for Outputs<T, N>

fn clone(&self) -> Outputs<T, N>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

impl<T: Default, const N: usize> Default for Outputs<T, N>

fn default() -> Outputs<T, N>

Returns the “default value” for a type.

impl<T, const N: usize> From<&Sender<T>> for Outputs<T, N>

fn from(input: &Sender<T>) -> Self

Converts to this type from the input type.

impl<T, const N: usize> From<Sender<T>> for Outputs<T, N>

fn from(input: Sender<T>) -> Self

Converts to this type from the input type.

impl<T, const N: usize> MaybeLabeled for Outputs<T, N>

fn label(&self) -> Option<Cow<'_, str>>

Returns the human-readable label, if any, of the object.

fn is_labeled(&self) -> bool

Checks whether the object has a human-readable label.

impl<T, const N: usize> MaybeNamed for Outputs<T, N>

fn name(&self) -> Option<Cow<'_, str>>

Returns the name, if any, of the object.

fn is_named(&self) -> bool

Checks whether the object has a name.

impl<T: Send + 'static, const N: usize> OutputPort<T> for Outputs<T, N>

fn send<'life0, 'async_trait>( &'life0 self, value: T, ) -> Pin<Box<dyn Future<Output = Result<(), SendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<T, const N: usize> Port<T> for Outputs<T, N>

fn is_closed(&self) -> bool

Checks if a port is closed.

fn close(&mut self)

Closes the port without dropping it.

fn is_open(&self) -> bool

Checks if a port is open.

fn capacity(&self) -> Option<usize>

Returns the remaining buffer capacity of the connection.

fn max_capacity(&self) -> Option<usize>

Returns the maximum buffer capacity of the connection.