diff --git a/src/main/scala/util/GroupedWithin.scala b/src/main/scala/util/GroupedWithin.scala index 61419b23..fbe064d4 100644 --- a/src/main/scala/util/GroupedWithin.scala +++ b/src/main/scala/util/GroupedWithin.scala @@ -6,6 +6,9 @@ import org.apache.pekko.actor.typed.Scheduler import scala.collection.immutable.VectorBuilder +/** Group elements into a fixed-sized buffer. The elements are emitted when the buffer is full, or + * periodically after a fixed time interval. + */ final class GroupedWithin()(using Scheduler, Executor): def apply[A](nb: Int, interval: FiniteDuration)(emit: Emit[Vector[A]]) =