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/05/29 02:16:58 UTC
(pekko) branch main updated: fix: Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators. (#1869)
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/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 572bebd619 fix: Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators. (#1869)
572bebd619 is described below
commit 572bebd619cf1050bd60c3360d48675155ca2d05
Author: He-Pin(kerr) <he...@gmail.com>
AuthorDate: Thu May 29 10:16:54 2025 +0800
fix: Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators. (#1869)
---
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 2 +-
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
index 56b4aa334f..9d703b6d45 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
@@ -1402,7 +1402,7 @@ trait FlowOps[+Out, +Mat] {
} else {
new MapAsyncPartitioned(parallelism, orderedOutput = false, partitioner, f)
}
- via(graph.withAttributes(DefaultAttributes.mapAsyncPartition and SourceLocation.forLambda(f)))
+ via(graph.withAttributes(DefaultAttributes.mapAsyncPartitionUnordered and SourceLocation.forLambda(f)))
}
/**
diff --git a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala
index 018317df77..eb5d5283a6 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala
@@ -527,7 +527,7 @@ object Source {
}
acc
}
- }).withAttributes(DefaultAttributes.iterableSource)
+ }).withAttributes(DefaultAttributes.iterateSource)
/**
* A `Source` with no elements, i.e. an empty stream that is completed immediately for every connected `Sink`.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org