Struct Inputs 

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

Implementations

impl<T> Inputs<T>

pub fn is_open(&self) -> bool

pub fn is_closed(&self) -> bool

pub fn is_empty(&self) -> bool

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

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

pub fn close(&mut self)

pub async fn recv_all(&mut self) -> Result<Vec<T>, RecvError>

pub async fn recv(&mut self) -> Result<Option<T>, RecvError>

Examples found in repository

examples/sqrt.rs (line 18)

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 13)

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 recv_blocking(&mut self) -> Result<Option<T>, RecvError>

Trait Implementations

impl<T> AsMut<Receiver<T>> for Inputs<T>

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

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

impl<T> AsRef<Receiver<T>> for Inputs<T>

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

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

impl<T> Debug for Inputs<T>

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

Formats the value using the given formatter.

impl<T: Default> Default for Inputs<T>

fn default() -> Inputs<T>

Returns the “default value” for a type.

impl<T> From<Receiver<T>> for Inputs<T>

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

Converts to this type from the input type.

impl<T: Send> InputPort<T> for Inputs<T>

fn is_empty(&self) -> bool

Checks if a port is empty.

fn recv<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<T>, RecvError>> + Send + 'async_trait>>

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

impl<T> MaybeLabeled for Inputs<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 Inputs<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> Port<T> for Inputs<T>

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.