Trait IComponentProcess

Source
pub trait IComponentProcess<TConfig, TMsg>
where TMsg: MsgDataBound,
{ // Required method fn process<'life0, 'async_trait>( &'life0 self, config: TConfig, in_out: CmpInOut<TMsg>, ) -> Pin<Box<dyn Future<Output = CmpResult> + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait; }
Expand description

Трейт основной функции компонента

Каждый компонент должен определить данный трейт

Required Methods§

Source

fn process<'life0, 'async_trait>( &'life0 self, config: TConfig, in_out: CmpInOut<TMsg>, ) -> Pin<Box<dyn Future<Output = CmpResult> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Основная функция компонента

Implementors§

Source§

impl<TMessage, TServerToClient, TClientToServer> IComponentProcess<Config<TMessage, TServerToClient, TClientToServer>, TMessage> for Component<Config<TMessage, TServerToClient, TClientToServer>, TMessage>
where TMessage: MsgDataBound + 'static, TServerToClient: WebsocketMessage + 'static, TClientToServer: WebsocketMessage + 'static,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound + 'static,

Компонент для добавления сообщений из побочного потока

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound + 'static,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound + 'static,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound + 'static,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound + 'static,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound + 'static,

Source§

impl<TMsg> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>
where TMsg: MsgDataBound + 'static,

Source§

impl<TMsg, I, Q, S> IComponentProcess<Config<TMsg, I, Q, S>, TMsg> for Component<Config<TMsg, I, Q, S>, TMsg>
where TMsg: MsgDataBound + 'static, I: Clone + Default + Send + Serialize + 'static + Sync, Q: Clone + Default + Send + Serialize + 'static + Sync, S: Clone + Default + Send + Serialize + 'static + Sync, FunctionBlockBase<I, Q, S>: IFunctionBlock<I, Q, S>,

Source§

impl<TMsg, TFnPeriodic> IComponentProcess<Config<TMsg, TFnPeriodic>, TMsg> for Component<Config<TMsg, TFnPeriodic>, TMsg>
where TMsg: MsgDataBound, TFnPeriodic: FnMut() -> Vec<Message<TMsg>> + Send + Sync,

Source§

impl<TMsg, TInputStore, TOutputStore> IComponentProcess<Config<TMsg, TInputStore, TOutputStore>, TMsg> for Component<Config<TMsg, TInputStore, TOutputStore>, TMsg>
where TMsg: MsgDataBound + 'static, TInputStore: StoreBound + 'static, TOutputStore: StoreBound + 'static,