Struct DoTryService 

pub struct DoTryService {
    pub try_steps: Vec<BoxProcessor>,
    pub catch_clauses: Vec<CatchClause>,
    pub finally_steps: Vec<BoxProcessor>,
    pub finally_on_when: Option<FilterPredicate>,
}

The doTry processor. Wrap with BoxProcessor::new(DoTryService::new(...)).

Fields

try_steps: Vec<BoxProcessor>

Steps in the try block.

catch_clauses: Vec<CatchClause>

Catch clauses evaluated first-match-wins.

finally_steps: Vec<BoxProcessor>

Steps in the finally block (empty = no finally).

finally_on_when: Option<FilterPredicate>

Optional onWhen predicate for finally.

Implementations

impl DoTryService

pub fn new(try_steps: Vec<BoxProcessor>) -> Self

Create a new DoTryService with the given try steps.

pub fn with_catch_and_finally( try_steps: Vec<BoxProcessor>, catch_clauses: Vec<CatchClause>, finally_steps: Vec<BoxProcessor>, finally_on_when: Option<FilterPredicate>, ) -> Self

Full constructor used by the compile pipeline (Task 10b control_flow.rs). Builder API (Task 8) constructs via new() + field mutation.

Trait Implementations

impl Clone for DoTryService

fn clone(&self) -> DoTryService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Service<Exchange> for DoTryService

type Response = Exchange

Responses given by the service.

type Error = CamelError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<DoTryService as Service<Exchange>>::Response, <DoTryService as Service<Exchange>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, exchange: Exchange) -> Self::Future

Process the request and return the response asynchronously.