Skip to content

Commit b5b393d

Browse files
rafaelingSebastianSchildt
authored andcommitted
Fix subset when publish single value
1 parent 821b926 commit b5b393d

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

databroker/src/broker.rs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2323,7 +2323,7 @@ impl AuthorizedAccess<'_, '_> {
23232323
.as_ref()
23242324
.unwrap()
23252325
.vss_ids;
2326-
key_set.is_subset(signal_request)
2326+
signal_request.is_subset(key_set)
23272327
}
23282328

23292329
pub async fn get_values_broker(
@@ -2454,9 +2454,11 @@ impl DataBroker {
24542454
// check which subscription contains a signal of the closed providers:
24552455
for (_, provider_signals_set) in closed_signal_providers {
24562456
for (_, subscription) in remaining_subscriptions.iter_mut() {
2457-
let key_set: HashSet<_> =
2457+
let subscription_key_set: HashSet<_> =
24582458
subscription.entries.keys().cloned().collect();
2459-
if key_set.is_subset(
2459+
2460+
// if they do have common elements
2461+
if !subscription_key_set.is_disjoint(
24602462
&provider_signals_set
24612463
.iter()
24622464
.map(|signal| signal.id())

0 commit comments

Comments
 (0)