Struct Config

pub struct Config<TMsg, TServerToClient, TClientToServer>
where
    TServerToClient: WebsocketMessage,
    TClientToServer: WebsocketMessage,
{
    pub serde_alg: SerdeAlgKind,
    pub url: String,
    pub fn_client_to_server: FnClientToServer<TMsg, TClientToServer>,
    pub fn_server_to_client: FnServerToClient<TMsg, TServerToClient>,
    pub fn_connection_state: fn(_: bool) -> Option<Message<TMsg>>,
}

Настройки Websocket-клиента

Fields

serde_alg: SerdeAlgKind

Алгоритм сериализации / десериализации

url: String

Адрес Websocket-сервера “ws://localhost:9001”

fn_client_to_server: FnClientToServer<TMsg, TClientToServer>

Преобразование входящих сообщений в текст для отправки на сервер

fn_server_to_client: FnServerToClient<TMsg, TServerToClient>

Преобразование полученного от сервера текста в исходящие сообщения

fn_connection_state: fn(_: bool) -> Option<Message<TMsg>>

Функция создает исходящее сообщение с информацией о соединении

В функцию передается состояние соединения;

• true - соединение установлено
• false - соединение разорвано

Примеры см. в тестах

Trait Implementations

impl<TMsg: Clone, TServerToClient, TClientToServer> Clone for Config<TMsg, TServerToClient, TClientToServer>

where TServerToClient: WebsocketMessage + Clone, TClientToServer: WebsocketMessage + Clone,

fn clone(&self) -> Config<TMsg, TServerToClient, TClientToServer>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<TMsg: Debug, TServerToClient, TClientToServer> Debug for Config<TMsg, TServerToClient, TClientToServer>

where TServerToClient: WebsocketMessage + Debug, TClientToServer: WebsocketMessage + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<TMsg, TServerToClient, TClientToServer> Default for Config<TMsg, TServerToClient, TClientToServer>

where TServerToClient: WebsocketMessage, TClientToServer: WebsocketMessage,

fn default() -> Self

Returns the “default value” for a type.

impl<TMessage, TServerToClient, TClientToServer> IComponentProcess<Config<TMessage, TServerToClient, TClientToServer>, TMessage> for Component<Config<TMessage, TServerToClient, TClientToServer>, TMessage>

where TMessage: MsgDataBound + 'static, TServerToClient: 'static + WebsocketMessage, TClientToServer: 'static + WebsocketMessage,

fn process<'life0, 'async_trait>( &'life0 self, config: Config<TMessage, TServerToClient, TClientToServer>, input: CmpInOut<TMessage>, ) -> Pin<Box<dyn Future<Output = Result<(), ComponentError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

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