This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 80cd63faf5 =str code clean up in Sliding.
80cd63faf5 is described below
commit 80cd63faf5cf9e09dc8d2647f7d4bebe7dd2c2ed
Author: He-Pin <[email protected]>
AuthorDate: Sat Dec 23 14:32:14 2023 +0800
=str code clean up in Sliding.
---
stream/src/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)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
