This is an automated email from the ASF dual-hosted git repository.

mdedetrich 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 5f2d690b89 Fix typos in optionalVia/unsafeOptionalVia
5f2d690b89 is described below

commit 5f2d690b8959a3ef0c65bca068624a1afd859079
Author: Matthew de Detrich <[email protected]>
AuthorDate: Fri Aug 30 10:51:50 2024 +0200

    Fix typos in optionalVia/unsafeOptionalVia
---
 stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala        | 2 +-
 .../main/scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala    | 2 +-
 stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala      | 2 +-
 .../main/scala/org/apache/pekko/stream/javadsl/SourceWithContext.scala  | 2 +-
 stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala       | 2 +-
 .../main/scala/org/apache/pekko/stream/scaladsl/FlowWithContext.scala   | 2 +-
 stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala     | 2 +-
 .../main/scala/org/apache/pekko/stream/scaladsl/SourceWithContext.scala | 2 +-
 8 files changed, 8 insertions(+), 8 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 043b5fe50c..245d7a2d1e 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
@@ -73,7 +73,7 @@ object Flow {
    * Creates a Flow from an existing base Flow outputting an optional element 
and
    * applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *
diff --git 
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala 
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala
index 2e058f8d11..f4f8806340 100644
--- 
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala
+++ 
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala
@@ -45,7 +45,7 @@ object FlowWithContext {
    * Creates a FlowWithContext from an existing base FlowWithContext 
outputting an optional element
    * and applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *
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 9affc6af15..5fdefb5081 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
@@ -141,7 +141,7 @@ object Source {
    * Creates a Source from an existing base Source outputting an optional 
element
    * and applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *
diff --git 
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SourceWithContext.scala 
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SourceWithContext.scala
index f41b7babfa..8478835b52 100644
--- 
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SourceWithContext.scala
+++ 
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SourceWithContext.scala
@@ -45,7 +45,7 @@ object SourceWithContext {
    * Creates a SourceWithContext from an existing base SourceWithContext 
outputting an optional element
    * and applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *
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 3b3876dbc8..372378d42b 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
@@ -432,7 +432,7 @@ object Flow {
    * Creates a FlowW from an existing base Flow outputting an optional element 
and
    * applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *
diff --git 
a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContext.scala 
b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContext.scala
index 87315e91ec..88e9e392c6 100644
--- 
a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContext.scala
+++ 
b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContext.scala
@@ -42,7 +42,7 @@ object FlowWithContext {
    * Creates a FlowWithContext from an existing base FlowWithContext 
outputting an optional element
    * and applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *
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 43ce87e3a2..018317df77 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
@@ -312,7 +312,7 @@ object Source {
    * Creates a Source from an existing base Source outputting an optional 
element
    * and applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *
diff --git 
a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/SourceWithContext.scala
 
b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/SourceWithContext.scala
index f98c445bf9..48f6a286ac 100644
--- 
a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/SourceWithContext.scala
+++ 
b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/SourceWithContext.scala
@@ -31,7 +31,7 @@ object SourceWithContext {
    * Creates a SourceWithContext from an existing base SourceWithContext 
outputting an optional element
    * and applying an additional viaFlow only if the element in the stream is 
defined.
    *
-   * '''Emits when''' the provided viaFlow is runs with defined elements
+   * '''Emits when''' the provided viaFlow runs with defined elements
    *
    * '''Backpressures when''' the viaFlow runs for the defined elements and 
downstream backpressures
    *


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to