Skip to content

Commit dc3ac6b

Browse files
committed
Close dynamic connection gracefully
Signed-off-by: James Rhodes <jarhodes314@gmail.com>
1 parent aada479 commit dc3ac6b

File tree

1 file changed

+2
-1
lines changed
  • crates/extensions/tedge_mqtt_ext/src

1 file changed

+2
-1
lines changed

crates/extensions/tedge_mqtt_ext/src/lib.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ impl FromPeers {
352352
.collect::<Vec<_>>();
353353
let mut tf = TopicFilter::empty();
354354
for sub in overlapping_subscriptions {
355-
tf.add_unchecked(&sub);
355+
tf.add_unchecked(sub);
356356
}
357357
let client = client.clone();
358358
tokio::spawn(async move {
@@ -386,6 +386,7 @@ impl FromPeers {
386386
}
387387
}
388388
}
389+
conn.close().await;
389390
});
390391
}
391392
}

0 commit comments

Comments
 (0)