Struct AsyncFunctionRouter 

pub struct AsyncFunctionRouter<S: StateSchema, F> { /* private fields */ }

Async function-based conditional router

Implementations

impl<S: StateSchema, F, Fut> AsyncFunctionRouter<S, F>

where F: Fn(&S) -> Fut + Send + Sync, Fut: Future<Output = Result<String, GraphError>> + Send,

pub fn new(func: F) -> Self

Create an async function-based conditional router.

Trait Implementations

impl<S: StateSchema, F, Fut> ConditionalEdge<S> for AsyncFunctionRouter<S, F>

where F: Fn(&S) -> Fut + Send + Sync, Fut: Future<Output = Result<String, GraphError>> + Send,

fn route<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 S, ) -> Pin<Box<dyn Future<Output = Result<String, GraphError>> + Send + 'async_trait>>

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

Route to next node based on state