Enum RecipientSource 

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

Fallible recipient source for the recipient list EIP.

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) -> String + Send + Sync>)

Programmatic synchronous closure producing a recipient.

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

Language-backed asynchronous expression.

Implementations

impl RecipientSource

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

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

Null coerces to the empty string; the empty string is allowed.

Trait Implementations

impl Clone for RecipientSource

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) -> Pin<Box<dyn Future<Output = Result<Value, CamelError>> + Send>> + Sync + Send>> for RecipientSource

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

Converts to this type from the input type.

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

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

Converts to this type from the input type.