You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by he...@apache.org on 2025/10/26 08:10:02 UTC
(pekko) branch oncloseTests created (now 52cc4d9da3)
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a change to branch oncloseTests
in repository https://gitbox.apache.org/repos/asf/pekko.git
at 52cc4d9da3 chore: fix FlowDoOnCancelSpec
This branch includes the following new commits:
new 52cc4d9da3 chore: fix FlowDoOnCancelSpec
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
(pekko) 01/01: chore: fix FlowDoOnCancelSpec
Posted by he...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch oncloseTests
in repository https://gitbox.apache.org/repos/asf/pekko.git
commit 52cc4d9da3d87f3704f47a5ec3502781eb5964d9
Author: He-Pin <he...@gmail.com>
AuthorDate: Sun Oct 26 16:09:48 2025 +0800
chore: fix FlowDoOnCancelSpec
---
.../scala/org/apache/pekko/stream/scaladsl/FlowDoOnCancelSpec.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDoOnCancelSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDoOnCancelSpec.scala
index 5b0eb45ae2..9f219b0aa6 100644
--- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDoOnCancelSpec.scala
+++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDoOnCancelSpec.scala
@@ -34,7 +34,7 @@ class FlowDoOnCancelSpec extends StreamSpec("""
promise.success(Done)
}
Source(1 to 10)
- .watchTermination()(Keep.right)
+ .watchTermination(Keep.right)
.via(Flow[Int].doOnCancel(f))
.toMat(Sink.cancelled)(Keep.left)
.run()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org