We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6712481 commit 89d1d7cCopy full SHA for 89d1d7c
src/channel.rs
@@ -59,11 +59,10 @@ async fn clean_up_unused_channels(
59
let mut channel_clients = state.channel_clients.lock().await;
60
61
if let Some(namespace_channels) = channel_clients.get_mut(&namespace) {
62
- if let Some((tx, _rx)) = namespace_channels.get(&channel_name) {
63
- if tx.sender_count() <= 1 && tx.receiver_count() <= 1 {
+ if let Some((tx, _rx)) = namespace_channels.get(&channel_name)
+ && tx.sender_count() <= 1 && tx.receiver_count() <= 1 {
64
namespace_channels.remove(&channel_name);
65
}
66
- }
67
68
if namespace_channels.is_empty() {
69
channel_clients.remove(&namespace);
0 commit comments