Struct AsyncFn 

pub struct AsyncFn<F, I, O, E = NodeError>
where
    F: for<'a> Fn(&'a I) -> Pin<Box<dyn Future<Output = Result<O, E>> + Send + 'a>> + Send + Sync + Clone + 'static,
    E: Error + Send + Sync + 'static,
{ /* private fields */ }

Wraps an asynchronous closure and exposes it as a TaskNode.

Implementations

impl<F, I, O, E> AsyncFn<F, I, O, E>

where F: for<'a> Fn(&'a I) -> Pin<Box<dyn Future<Output = Result<O, E>> + Send + 'a>> + Send + Sync + Clone + 'static, I: NodeArg + Clone, O: NodeArg + Clone, E: Error + Send + Sync + 'static,

pub fn new(f: F) -> Self

Creates a new asynchronous task-node adapter from f.

Trait Implementations

impl<F, I, O, E> Clone for AsyncFn<F, I, O, E>

where F: for<'a> Fn(&'a I) -> Pin<Box<dyn Future<Output = Result<O, E>> + Send + 'a>> + Send + Sync + Clone + 'static, E: Error + Send + Sync + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F> From<F> for AsyncFn<F, (), ()>

where F: for<'a> Fn(&'a ()) -> Pin<Box<dyn Future<Output = Result<(), NodeError>> + Send + 'a>> + Send + Sync + Clone + 'static,

fn from(f: F) -> Self

Converts to this type from the input type.

impl<F, I, O, E> TaskNode for AsyncFn<F, I, O, E>

where F: for<'a> Fn(&'a I) -> Pin<Box<dyn Future<Output = Result<O, E>> + Send + 'a>> + Clone + Send + Sync + 'static, I: NodeArg + Clone, O: NodeArg + Clone, E: Error + Send + Sync + 'static,

type Input = I

The input accepted by this node.

type Output = O

The output produced by this node.

type Error = E

The error returned when evaluation fails.

fn evaluate<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _node_id: &'life1 NodeId<dyn TaskNode<Input = Self::Input, Output = Self::Output, Error = Self::Error>>, input: &'life2 Self::Input, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Evaluates the node with the current input.