gmqtt_client/client/
config.rs

1use mqttbytes::v5::SubscribeFilter;
2
3use super::Message;
4use std::time::Instant;
5
6pub type OnMessageCallback = dyn Fn(&Message) + Send + Sync + 'static;
7pub type OnMessageOwnedCallback = dyn Fn(Message, Instant) + Send + 'static;
8pub type OnConnectedCallback = dyn Fn() + Send + Sync + 'static;
9
10pub(crate) struct MqttClientConfig {
11    pub client_id: String,
12    pub subscribe_filters: Vec<SubscribeFilter>,
13    pub on_message_callback: Option<Box<OnMessageCallback>>,
14    pub on_connected_callback: Option<Box<OnConnectedCallback>>,
15    pub clean_session: bool,
16}