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 6b3096c28a chore: Add special `null` value handling doc for mapAsync
and mapAsyncUnordered.
6b3096c28a is described below
commit 6b3096c28ab1233bae580e80e0e08c6daaa09843
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.
---
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 948b220544..3e2330abf3 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
@@ -821,7 +821,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.
*
@@ -919,7 +920,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 91cd27aa48..edaff38f1b 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
@@ -2495,7 +2495,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.
*
@@ -2595,7 +2596,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 25cf5107b1..93942830b9 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 15f407f069..14c441f3e4 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 e409541419..a73822fec1 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
@@ -1088,7 +1088,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.
*
@@ -1123,7 +1124,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]
