Struct fmodel_rust::saga_manager::SagaManager

pub struct SagaManager<'a, A, AR, Publisher, Error>where
    Publisher: ActionPublisher<A, Error>,{ /* private fields */ }

Saga Manager.

It is using a Saga to react to the action result and to publish the new actions. It is using an ActionPublisher to publish the new actions.

Generic parameters:

• A - Action / Command
• AR - Action Result / Event
• Publisher - Action Publisher
• Error - Error

Implementations

impl<'a, A, AR, Publisher, Error> SagaManager<'a, A, AR, Publisher, Error>where Publisher: ActionPublisher<A, Error>,

pub fn new(action_publisher: Publisher, saga: Saga<'a, AR, A>) -> Self

Creates a new instance of SagaManager.

pub async fn handle(&self, action_result: &AR) -> Result<Vec<A>, Error>

Handles the action result by publishing it to the external system.