diff options
| author | Marcel Müller <neikos@neikos.email> | 2023-01-02 09:27:54 +0100 |
|---|---|---|
| committer | Marcel Müller <neikos@neikos.email> | 2023-01-02 14:05:11 +0100 |
| commit | 013f119b7719e136fd8dcbbc6cf96ac245b2587a (patch) | |
| tree | 93371fede0da136a50633ea1d5f7214838e79763 | |
| parent | cac920d81ebae614effce1832c279702d415c93f (diff) | |
Move ClientState dashmap behind Arc
Signed-off-by: Marcel Müller <neikos@neikos.email>
| -rw-r--r-- | src/server/mod.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/server/mod.rs b/src/server/mod.rs index 1527645..2a13c92 100644 --- a/src/server/mod.rs +++ b/src/server/mod.rs @@ -125,7 +125,7 @@ impl ClientSource { /// Check out the server example for a working version. /// pub struct MqttServer { - clients: DashMap<ClientId, ClientState>, + clients: Arc<DashMap<ClientId, ClientState>>, client_source: ClientSource, subscription_manager: SubscriptionManager, } @@ -138,7 +138,7 @@ impl MqttServer { let bind = TcpListener::bind(addr).await?; Ok(MqttServer { - clients: DashMap::new(), + clients: Arc::new(DashMap::new()), client_source: ClientSource::UnsecuredTcp(bind), subscription_manager: SubscriptionManager::new(), }) |