This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch 1.0.x
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/1.0.x by this push:
new 614560e0a8 chore: Add special `null` value handling doc for mapAsync
and mapAsyncUnordered.
614560e0a8 is described below
commit 614560e0a8f6a567d46b4cbe20f45019cb8cc4d5
Author: He-Pin <[email protected]>
AuthorDate: Sun Dec 24 14:20:54 2023 +0800
chore: Add special `null` value handling doc for mapAsync and
mapAsyncUnordered.
(cherry picked from commit 6b3096c28ab1233bae580e80e0e08c6daaa09843)
---
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 6 ++++--
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala | 6 ++++--
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala | 6 ++++--
.../src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala | 6 ++++--
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 6 ++++--
5 files changed, 20 insertions(+), 10 deletions(-)
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
index 96bca18fb5..1be8382665 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
@@ -810,7 +810,8 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In,
Out, Mat]) extends Gr
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive.
*
@@ -842,7 +843,8 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In,
Out, Mat]) extends Gr
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive (even though the result of the futures
* returned by `f` might be emitted in a different order).
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
index 2237fef9eb..92da988485 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
@@ -2479,7 +2479,8 @@ final class Source[Out, Mat](delegate:
scaladsl.Source[Out, Mat]) extends Graph[
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive.
*
@@ -2513,7 +2514,8 @@ final class Source[Out, Mat](delegate:
scaladsl.Source[Out, Mat]) extends Graph[
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive (even though the result of the CompletionStages
* returned by `f` might be emitted in a different order).
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
index 1b6309ff83..b53e486b71 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
@@ -294,7 +294,8 @@ class SubFlow[In, Out, Mat](
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive.
*
@@ -328,7 +329,8 @@ class SubFlow[In, Out, Mat](
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive (even though the result of the CompletionStages
* returned by `f` might be emitted in a different order).
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
index 6104422b66..0338dbf069 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
@@ -285,7 +285,8 @@ class SubSource[Out, Mat](
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive.
*
@@ -319,7 +320,8 @@ class SubSource[Out, Mat](
*
* If the function `f` throws an exception or if the `CompletionStage` is
completed
* with failure and the supervision decision is
[[pekko.stream.Supervision#resume]] or
- * [[pekko.stream.Supervision#restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision#restart]] or the `CompletionStage` completed
with `null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive (even though the result of the futures
* returned by `f` might be emitted in a different order).
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 d6f3bb9275..b137d27b47 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
@@ -1076,7 +1076,8 @@ trait FlowOps[+Out, +Mat] {
*
* If the function `f` throws an exception or if the `Future` is completed
* with failure and the supervision decision is
[[pekko.stream.Supervision.Resume]] or
- * [[pekko.stream.Supervision.Restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision.Restart]] or the `Future` completed with
`null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive.
*
@@ -1111,7 +1112,8 @@ trait FlowOps[+Out, +Mat] {
*
* If the function `f` throws an exception or if the `Future` is completed
* with failure and the supervision decision is
[[pekko.stream.Supervision.Resume]] or
- * [[pekko.stream.Supervision.Restart]] the element is dropped and the
stream continues.
+ * [[pekko.stream.Supervision.Restart]] or the `Future` completed with
`null`,
+ * the element is dropped and the stream continues.
*
* The function `f` is always invoked on the elements in the order they
arrive (even though the result of the futures
* returned by `f` might be emitted in a different order).
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
