diff --git a/stream-android-core/src/test/java/io/getstream/android/core/internal/processing/StreamEventAggregatorImplTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/internal/processing/StreamEventAggregatorImplTest.kt
index c197c4c..4ef9b38 100644
--- a/stream-android-core/src/test/java/io/getstream/android/core/internal/processing/StreamEventAggregatorImplTest.kt
+++ b/stream-android-core/src/test/java/io/getstream/android/core/internal/processing/StreamEventAggregatorImplTest.kt
@@ -841,6 +841,10 @@ class StreamEventAggregatorImplTest {
                         deserializer = deserializer,
                         aggregationThreshold = threshold,
                         maxWindowMs = 500,
+                        // A full dispatch queue drops events by design, and the collector can
+                        // outrun the dispatcher when the inbox is flooded. Every queued item holds
+                        // at least one event, so this capacity can never fill up.
+                        dispatchQueueCapacity = totalEvents,
                     ),
             )