Enum TargetSource 

#[non_exhaustive]
pub enum TargetSource {
    Sync(Arc<dyn Fn(&Exchange) -> Option<String> + Send + Sync>),
    Async(Arc<dyn Fn(&Exchange) -> BoxValueFuture + Send + Sync>),
}

Fallible target source for dynamic routers and routing slips.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Sync(Arc<dyn Fn(&Exchange) -> Option<String> + Send + Sync>)

Programmatic synchronous closure producing an optional target.

Async(Arc<dyn Fn(&Exchange) -> BoxValueFuture + Send + Sync>)

Language-backed asynchronous expression.

Implementations

impl TargetSource

pub async fn resolve( &self, exchange: &Exchange, ) -> Result<Option<String>, CamelError>

Resolve the target, propagating async failures and non-scalar values.

Trait Implementations

impl Clone for TargetSource

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl From<Arc<dyn Fn(&Exchange) -> Option<String> + Sync + Send>> for TargetSource

fn from(f: Arc<dyn Fn(&Exchange) -> Option<String> + Send + Sync>) -> Self

Converts to this type from the input type.

impl From<Arc<dyn Fn(&Exchange) -> Pin<Box<dyn Future<Output = Result<Value, CamelError>> + Send>> + Sync + Send>> for TargetSource

fn from(f: Arc<dyn Fn(&Exchange) -> BoxValueFuture + Send + Sync>) -> Self

Converts to this type from the input type.