Struct Outputs 

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

Implementations

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

pub fn close(&mut self)

pub fn direction(&self) -> PortDirection

pub fn state(&self) -> PortState

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

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

pub async fn send(&self, message: 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 async fn send_event(&self, event: PortEvent<T>) -> Result<(), SendError>

pub fn blocking_send(&self, _message: T) -> Result<(), SendError>

Trait Implementations

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

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

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

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

fn as_ref(&self) -> &Sender<PortEvent<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<PortEvent<T>>> for Outputs<T, N>

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

Converts to this type from the input type.

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

fn from(input: Sender<PortEvent<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, message: T, ) -> Pin<Box<dyn Future<Output = Result<(), SendError>> + Send + 'async_trait>>

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

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

fn close(&mut self)

Closes this port without dropping it, returning immediately.

fn direction(&self) -> PortDirection

The dataflow direction of this port.

fn state(&self) -> PortState

The current state of this port.

fn is_input(&self) -> bool

Checks whether this port is an input port.

fn is_output(&self) -> bool

Checks whether this port is an output port.

fn is_unconnected(&self) -> bool

Checks whether this port is currently unconnected.

fn is_connected(&self) -> bool

Checks whether this port is currently connected.

fn is_disconnected(&self) -> bool

Checks whether this port is currently disconnected.

fn is_closed(&self) -> bool

Checks whether this port is currently closed.

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.