From 9ac3843e0d232ba8e80c363e36a3ffef032704cc Mon Sep 17 00:00:00 2001 From: Fabio Labella Date: Sat, 3 Oct 2020 00:32:44 +0100 Subject: [PATCH] Start the initial timer in groupWithin with TimedPull --- core/shared/src/main/scala/fs2/concurrent/TimedPull.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/shared/src/main/scala/fs2/concurrent/TimedPull.scala b/core/shared/src/main/scala/fs2/concurrent/TimedPull.scala index 17bd38fa11..b5a2cdd7f4 100644 --- a/core/shared/src/main/scala/fs2/concurrent/TimedPull.scala +++ b/core/shared/src/main/scala/fs2/concurrent/TimedPull.scala @@ -117,7 +117,7 @@ object tp { } } - go(Chunk.Queue.empty, tp) + tp.startTimer(t) >> go(Chunk.Queue.empty, tp) }.apply(s) import cats.effect.unsafe.implicits.global