Struct SubmitAdjudicationUseCase 

pub struct SubmitAdjudicationUseCase<P>
where
    P: PersistencePort + Send + Sync + 'static,
{ /* private fields */ }

Sync use-case: apply an oracle verdict atomically.

Invoked via spawn_blocking by EngineHandle::submit_adjudication.

Implementations

impl<P> SubmitAdjudicationUseCase<P>

where P: PersistencePort + Send + Sync + 'static,

pub fn new( persistence: Arc<P>, pending_store: Arc<dyn ErasedPendingStore>, ) -> Self

pub fn execute( &self, handle_id: Uuid, response: AdjudicationResponse, now: DateTime<Utc>, ) -> Result<AdjudicationOutcome, MemError>

Execute the verdict-apply algorithm.

now is engine-stamped at the async boundary and passed in (DETERMINISM).