Struct Outputs 

pub struct Outputs<T> { /* private fields */ }

Implementations

impl<T> Outputs<T>

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

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

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::bounded(1);

    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> AsMut<Sender<T>> for Outputs<T>

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

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

impl<T> AsRef<Sender<T>> for Outputs<T>

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

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

impl<T: Clone> Clone for Outputs<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Outputs<T>

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

Formats the value using the given formatter.

impl<T> From<&Sender<T>> for Outputs<T>

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

Converts to this type from the input type.

impl<T> From<Sender<T>> for Outputs<T>

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

Converts to this type from the input type.

impl<T> MaybeLabeled for Outputs<T>

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> MaybeNamed for Outputs<T>

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> OutputPort<T> for Outputs<T>

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> Port<T> for Outputs<T>

fn is_closed(&self) -> bool

Checks if a port is closed.

fn close(&mut self)

Closes the port without dropping it.

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.