Enable strict control over readers

Eventuous · May 11, 2022 · 1dbb849 · 1dbb849
1 parent acde578
commit 1dbb849
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Core/src/Eventuous.Subscriptions/Filters/ConcurrentFilter.cs b/src/Core/src/Eventuous.Subscriptions/Filters/ConcurrentFilter.cs
@@ -14,7 +14,7 @@ public ConcurrentFilter(uint concurrencyLimit, uint bufferSize = 10) {
         var capacity = (int)(concurrencyLimit * bufferSize);
 
         var options = new BoundedChannelOptions(capacity) {
-            SingleReader = true, SingleWriter = true
+            SingleReader = concurrencyLimit == 1, SingleWriter = true
         };
 
         _worker = new ConcurrentChannelWorker<WorkerTask>(