From 80cd63faf5cf9e09dc8d2647f7d4bebe7dd2c2ed Mon Sep 17 00:00:00 2001 From: He-Pin Date: Sat, 23 Dec 2023 14:32:14 +0800 Subject: [PATCH] =str code clean up in Sliding. --- .../main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala index 9d1ce1a0b2..d70b1c9bbb 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala @@ -903,7 +903,7 @@ private[stream] object Collect { if (buf.size == n) { push(out, buf) } else pull(in) - } else if (step > n) { + } else { if (buf.size == step) { buf = buf.drop(step) }