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-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new d91037fb5 Remove redundant semicolons
d91037fb5 is described below
commit d91037fb5c5c3d6f4c5ee6ed994331763a8fbacb
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sat May 27 12:21:50 2023 +0200
Remove redundant semicolons
---
dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala | 2 +-
dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala | 2 +-
influxdb/src/test/scala/docs/scaladsl/InfluxDbSourceSpec.scala | 10 +++++-----
3 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
b/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
index 8de886ca8..1f1ff9a31 100644
--- a/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
+++ b/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
@@ -80,7 +80,7 @@ class ExampleSpec
// #init-client
override def afterAll(): Unit = {
- client.close();
+ client.close()
shutdown()
super.afterAll()
}
diff --git a/dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala
b/dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala
index 17da26067..639f8da71 100644
--- a/dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala
+++ b/dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala
@@ -64,7 +64,7 @@ class RetrySpec
override def afterAll(): Unit = {
client.close()
- shutdown();
+ shutdown()
}
}
diff --git a/influxdb/src/test/scala/docs/scaladsl/InfluxDbSourceSpec.scala
b/influxdb/src/test/scala/docs/scaladsl/InfluxDbSourceSpec.scala
index 32174a4ba..14a842a49 100644
--- a/influxdb/src/test/scala/docs/scaladsl/InfluxDbSourceSpec.scala
+++ b/influxdb/src/test/scala/docs/scaladsl/InfluxDbSourceSpec.scala
@@ -57,7 +57,7 @@ class InfluxDbSourceSpec
"support source" in assertAllStagesStopped {
// #run-typed
- val query = new Query("SELECT * FROM cpu", DatabaseName);
+ val query = new Query("SELECT * FROM cpu", DatabaseName)
val influxDBResult = InfluxDbSource(influxDB, query).runWith(Sink.seq)
val resultToAssert = influxDBResult.futureValue.head
@@ -68,7 +68,7 @@ class InfluxDbSourceSpec
}
"exception on source" in assertAllStagesStopped {
- val query = new Query("SELECT man() FROM invalid", DatabaseName);
+ val query = new Query("SELECT man() FROM invalid", DatabaseName)
val result = InfluxDbSource(influxDB, query) // .runWith(Sink.seq)
.recover {
@@ -81,7 +81,7 @@ class InfluxDbSourceSpec
}
"partial error in query" in assertAllStagesStopped {
- val query = new Query("SELECT*FROM cpu; SELECT man() FROM invalid",
DatabaseName);
+ val query = new Query("SELECT*FROM cpu; SELECT man() FROM invalid",
DatabaseName)
val influxDBResult = InfluxDbSource(influxDB, query).runWith(Sink.seq)
val resultToAssert = influxDBResult.futureValue.head
@@ -94,7 +94,7 @@ class InfluxDbSourceSpec
}
"exception on typed source" in assertAllStagesStopped {
- val query = new Query("SELECT man() FROM invalid", DatabaseName);
+ val query = new Query("SELECT man() FROM invalid", DatabaseName)
val result = InfluxDbSource
.typed(classOf[InfluxDbSourceCpu], InfluxDbReadSettings.Default,
influxDB, query) // .runWith(Sink.seq)
@@ -108,7 +108,7 @@ class InfluxDbSourceSpec
}
"mixed exception on typed source" in assertAllStagesStopped {
- val query = new Query("SELECT*FROM cpu;SELECT man() FROM invalid;
SELECT*FROM cpu;", DatabaseName);
+ val query = new Query("SELECT*FROM cpu;SELECT man() FROM invalid;
SELECT*FROM cpu;", DatabaseName)
val result = InfluxDbSource
.typed(classOf[InfluxDbSourceCpu], InfluxDbReadSettings.Default,
influxDB, query) // .runWith(Sink.seq)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
