Mountain/RunTime/Execute/
RunWithTimeout.rs

1#![allow(non_snake_case)]
2
3//! Cancel an effect that exceeds a wall-clock budget. Wraps `Run` in
4//! `tokio::time::timeout` and converts the elapsed-error into
5//! `CommonError::Unknown`.
6
7use std::sync::Arc;
8
9use CommonLibrary::{
10	Effect::{ActionEffect::ActionEffect, ApplicationRunTime::ApplicationRunTime as ApplicationRunTimeTrait},
11	Environment::Requires::Requires,
12	Error::CommonError::CommonError,
13};
14
15use crate::RunTime::ApplicationRunTime::ApplicationRunTime;
16
17impl ApplicationRunTime {
18	pub async fn RunWithTimeout<TCapabilityProvider, TError, TOutput>(
19		&self,
20		Effect:ActionEffect<Arc<TCapabilityProvider>, TError, TOutput>,
21		Timeout:std::time::Duration,
22	) -> Result<TOutput, TError>
23	where
24		TCapabilityProvider: ?Sized + Send + Sync + 'static,
25		<Self as CommonLibrary::Environment::HasEnvironment::HasEnvironment>::EnvironmentType:
26			Requires<TCapabilityProvider>,
27		TError: From<CommonError> + Send + Sync + 'static,
28		TOutput: Send + Sync + 'static, {
29		tokio::time::timeout(Timeout, ApplicationRunTimeTrait::Run(self, Effect))
30			.await
31			.map_err(|_| {
32				CommonError::Unknown { Description:format!("Effect execution timed out after {:?}", Timeout) }.into()
33			})?
34	}
35}
Mountain/RunTime/Execute/RunWithTimeout.rs

Mountain/RunTime/Execute/
RunWithTimeout.rs
