rsiot/components/cmp_http_client_wasm/
component.rsuse async_trait::async_trait;
use crate::{
executor::{CmpInOut, Component, ComponentError, IComponentProcess},
message::{AuthPermissions, MsgDataBound, ServiceBound},
};
use super::{config::ConfigAlias, fn_process::fn_process};
#[allow(unreachable_code)]
#[cfg(not(feature = "single-thread"))]
#[async_trait]
impl<TMsg> IComponentProcess<ConfigAlias<TMsg>, TMsg> for Component<ConfigAlias<TMsg>, TMsg>
where
TMsg: MsgDataBound + 'static,
{
async fn process(
&self,
_config: ConfigAlias<TMsg>,
_input: CmpInOut<TMsg>,
) -> Result<(), ComponentError> {
unimplemented!();
let config = _config.0;
fn_process(_input, config)
.await
.map_err(|err| ComponentError::Execution(err.to_string()))
}
}
#[cfg(feature = "single-thread")]
#[async_trait(?Send)]
impl<TMsg, TService> IComponentProcess<ConfigAlias<TMsg>, TMsg, TService>
for Component<ConfigAlias<TMsg>, TMsg, TService>
where
TMsg: MsgDataBound + 'static,
TService: ServiceBound + 'static,
{
async fn process(
&self,
config: ConfigAlias<TMsg>,
in_out: CmpInOut<TMsg, TService>,
) -> Result<(), ComponentError> {
let config = config.0;
fn_process(
in_out.clone_with_new_id("cmp_http_client_wasm", AuthPermissions::FullAccess),
config,
)
.await
.map_err(|err| ComponentError::Execution(err.to_string()))
}
}
pub type Cmp<TMsg, TService> = Component<ConfigAlias<TMsg>, TMsg, TService>;