Struct rsiot_websocket_server::cmp_websocket_server::Config

pub struct Config<TMsg> {
    pub port: u16,
    pub fn_input: fn(_: &Message<TMsg>) -> Result<Option<String>, Error>,
    pub fn_output: fn(_: &str) -> Result<Option<Vec<Message<TMsg>>>, Error>,
}

Конфигурация Websocket-сервера

Fields

port: u16

Порт, через который доступен сервер

fn_input: fn(_: &Message<TMsg>) -> Result<Option<String>, Error>

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

Примеры

Заглушка

fn_input: |_| Ok(None),

Сериализация в json

fn_input: |msg: &Message<Custom>| {
    let text = msg.serialize()?;
    Ok(Some(text))
}

fn_output: fn(_: &str) -> Result<Option<Vec<Message<TMsg>>>, Error>

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

Примеры

Заглушка

fn_output: |_| Ok(None)

Десериализация из json:

fn_output: |text: &str| {
    let msg = Message::<Custom>::deserialize(text)?;
    Ok::<Option<Vec<Message<Custom>>>, anyhow::Error>(Some(vec![msg]))
}

Trait Implementations

impl<TMsg> Clone for Config<TMsg>

where TMsg: Clone,

fn clone(&self) -> Config<TMsg>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<TMsg> Debug for Config<TMsg>

where TMsg: Debug,

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

Formats the value using the given formatter.