Enum SplitSource 

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

Fallible split source: a synchronous SplitExpression or a language-backed asynchronous expression.

The async arm evaluates to a Value; fragments are derived with the canonical split rules (string → non-empty line fragments, array → one fragment per element). Evaluation errors propagate before any fragment is materialized.

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(SplitExpression)

Programmatic synchronous splitter.

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

Language-backed asynchronous expression.

Implementations

impl SplitSource

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

Split exchange into fragments, propagating evaluation failures.

Trait Implementations

impl Clone for SplitSource

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) -> Result<Vec<Exchange>, CamelError> + Sync + Send>> for SplitSource

fn from(f: SplitExpression) -> Self

Converts to this type from the input type.