raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Remove unneeded semicolons

Browse source
This commit is contained in:
Matthew de Detrich 2022-11-30 16:55:08 +01:00 • committed by Matthew de Detrich
parent f84e8db3cb
commit 9be4cad14f
2 changed files with 17 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

18
akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/AsSubscriber.scala
View file

@ -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
}

16
akka-docs/src/test/scala-jdk9-only/docs/stream/operators/source/FromPublisher.scala
View file

@ -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
}