From 9be4cad14fdab9702a8db1c657a3fcac135bba48 Mon Sep 17 00:00:00 2001 From: Matthew de Detrich Date: Wed, 30 Nov 2022 16:55:08 +0100 Subject: [PATCH] Remove unneeded semicolons --- .../stream/operators/source/AsSubscriber.scala | 18 +++++++++--------- .../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. */ -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. */ -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 }