Specify comparison rule in topic filter

Advanced-Systems · Aug 31, 2024 · 95e97fa · 95e97fa
1 parent 3709dc2
commit 95e97fa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/AdvancedSystems.Core/Services/MessageBus.cs b/AdvancedSystems.Core/Services/MessageBus.cs
@@ -59,7 +59,7 @@ public async ValueTask PublishAsync<T>(T message, string? topic = default, Cance
 
         topic ??= DEFAULT_TOPIC;
         var snapshot = this._broadcasts.Values
-            .Where(x => string.Equals(x.Topic, topic))
+            .Where(x => string.Equals(x.Topic, topic, StringComparison.Ordinal))
             .ToList();
 
         if (snapshot.Count == 0) throw new InvalidOperationException($"Unknown topic ('{topic}').");