diff --git a/src/Core/src/Eventuous.Subscriptions/Filters/ConcurrentFilter.cs b/src/Core/src/Eventuous.Subscriptions/Filters/ConcurrentFilter.cs
index e79c55f6..77fc3e78 100644
--- 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>(