pub trait IComponentFunction<TMessage, TConfig>: Send {
// Required method
fn call(
&self,
stream_input: Input<TMessage>,
stream_output: Output<TMessage>,
config: TConfig
) -> BoxFuture<'static, ()>;
}
Expand description
Трейт для функции компонента