@@ -176,7 +176,9 @@ def writer():
         # Check timing and received waiting state
         assert r == ready
         if check_timing(request):
-            exptime = {waiting.Ready.R: delay, waiting.Ready.NONE: interval}[ready]
+            exptime = {waiting.Ready.R: delay, waiting.Ready.NONE: nevents * interval}[
+                ready
+            ]
             assert exptime <= dt < exptime * 1.2
     finally:
         gather(*tasks)
 
@@ -184,7 +184,10 @@ async def writer():
         # Check timing and received waiting state
         assert r == ready
         if check_timing(request):
-            exptime = {waiting.Ready.R: delay, waiting.Ready.NONE: interval}[ready]
+            exptime = {
+                waiting.Ready.R: delay,
+                waiting.Ready.NONE: nevents * interval,
+            }[ready]
             assert exptime <= dt < (exptime * 1.2)
     finally:
         await gather(*tasks)