cp_microservice/storage/
executor.rs

1use std::{pin::Pin, sync::Arc};
2
3use futures_util::Future;
4
5use crate::core::error::Error;
6
7pub type Executor<StorageRequestType> = Arc<
8    dyn Fn(StorageRequestType) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + Sync>>
9        + Send
10        + Sync,
11>;