You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by md...@apache.org on 2022/11/30 17:43:28 UTC
[incubator-pekko] branch main updated: Remove unneeded semicolons
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/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 9be4cad14f Remove unneeded semicolons
9be4cad14f is described below
commit 9be4cad14fdab9702a8db1c657a3fcac135bba48
Author: Matthew de Detrich <ma...@aiven.io>
AuthorDate: Wed Nov 30 16:55:08 2022 +0100
Remove unneeded semicolons
---
.../docs/stream/operators/source/AsSubscriber.scala | 18 +++++++++---------
.../docs/stream/operators/source/FromPublisher.scala | 16 ++++++++--------
2 files changed, 17 insertions(+), 17 deletions(-)
diff --git a/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/AsSubscriber.scala b/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/AsSubscriber.scala
index 24690d805d..444f6d947d 100644
--- a/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/AsSubscriber.scala
+++ b/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/AsSubscriber.scala
@@ -2,16 +2,16 @@
* Copyright (C) 2019-2022 Lightbend Inc. <https://www.lightbend.com>
*/
-package docs.stream.operators.source;
+package docs.stream.operators.source
//#imports
-import java.util.concurrent.Flow.Subscriber;
-import java.util.concurrent.Flow.Publisher;
+import java.util.concurrent.Flow.Subscriber
+import java.util.concurrent.Flow.Publisher
-import org.apache.pekko;
-import pekko.NotUsed;
-import pekko.stream.scaladsl.Source;
-import pekko.stream.scaladsl.JavaFlowSupport;
+import org.apache.pekko
+import pekko.NotUsed
+import pekko.stream.scaladsl.Source
+import pekko.stream.scaladsl.JavaFlowSupport
//#imports
@@ -22,7 +22,7 @@ object AsSubscriber {
def fetchRows(): Publisher[Row] = ???
}
- val databaseClient: DatabaseClient = ???;
+ val databaseClient: DatabaseClient = ???
// #example
val rowSource: Source[Row, NotUsed] =
@@ -38,6 +38,6 @@ object AsSubscriber {
// rowSource can be re-used, since it will start a new
// query for each materialization, fully supporting backpressure
// for each materialized stream:
- rowSource.map(row => row.name);
+ rowSource.map(row => row.name)
// #example
}
diff --git a/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/FromPublisher.scala b/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/FromPublisher.scala
index ada3ec061d..a1f501dee5 100644
--- a/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/FromPublisher.scala
+++ b/akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/FromPublisher.scala
@@ -2,16 +2,16 @@
* Copyright (C) 2020-2022 Lightbend Inc. <https://www.lightbend.com>
*/
-package docs.stream.operators.source;
+package docs.stream.operators.source
//#imports
-import java.util.concurrent.Flow.Subscriber;
-import java.util.concurrent.Flow.Publisher;
+import java.util.concurrent.Flow.Subscriber
+import java.util.concurrent.Flow.Publisher
-import org.apache.pekko;
-import pekko.NotUsed;
-import pekko.stream.scaladsl.Source;
-import pekko.stream.scaladsl.JavaFlowSupport;
+import org.apache.pekko
+import pekko.NotUsed
+import pekko.stream.scaladsl.Source
+import pekko.stream.scaladsl.JavaFlowSupport
//#imports
@@ -30,6 +30,6 @@ object FromPublisher {
// materialization, so depending on whether the database client supports
// this the Source can be materialized more than once.
JavaFlowSupport.Source.fromPublisher(databaseClient.fetchRows())
- .map(row => row.name);
+ .map(row => row.name)
// #example
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org