cp_microservice/api/server/input/
executor.rs

1use std::future::Future;
2use std::pin::Pin;
3use std::sync::Arc;
4
5use async_channel::Sender;
6use serde_json::Value;
7
8use crate::api::shared::request::Request;
9use crate::core::error::Error;
10
11pub type Executor<LogicRequestType> = Arc<
12    dyn Fn(
13            Request,
14            Sender<LogicRequestType>,
15        ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + Sync>>
16        + Send
17        + Sync,
18>;