From 5f2d690b8959a3ef0c65bca068624a1afd859079 Mon Sep 17 00:00:00 2001 From: Matthew de Detrich Date: Fri, 30 Aug 2024 10:51:50 +0200 Subject: [PATCH] Fix typos in optionalVia/unsafeOptionalVia --- .../src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 2 +- .../scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala | 2 +- .../src/main/scala/org/apache/pekko/stream/javadsl/Source.scala | 2 +- .../org/apache/pekko/stream/javadsl/SourceWithContext.scala | 2 +- .../src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 2 +- .../org/apache/pekko/stream/scaladsl/FlowWithContext.scala | 2 +- .../main/scala/org/apache/pekko/stream/scaladsl/Source.scala | 2 +- .../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 *