This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 01eaf1924 Update scalafmt-core to 3.10.5 (#1386)
01eaf1924 is described below
commit 01eaf19247cea976658e02dd00889214cd4b92b7
Author: Scala Steward <[email protected]>
AuthorDate: Wed Jan 28 18:08:18 2026 +0100
Update scalafmt-core to 3.10.5 (#1386)
* Update scalafmt-core to 3.10.5
* Reformat with scalafmt 3.10.5
Executed command: scalafmt --non-interactive
* Add 'Reformat with scalafmt 3.10.5' to .git-blame-ignore-revs
---
.git-blame-ignore-revs | 3 +++
.scalafmt.conf | 2 +-
.../scaladsl/AmqpGraphStageLogicConnectionShutdownSpec.scala | 5 ++++-
.../org/apache/pekko/stream/connectors/awsspi/TestBase.scala | 4 +++-
.../pekko/stream/connectors/awsspi/sqs/SQSITTest.scala | 5 ++++-
.../src/test/scala/docs/scaladsl/CassandraFlowSpec.scala | 5 ++++-
.../stream/connectors/couchbase/javadsl/CouchbaseFlow.scala | 6 +++++-
.../stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala | 11 +++++++++--
.../src/test/scala/docs/scaladsl/CouchbaseFlowSpec.scala | 6 +++++-
.../apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala | 5 ++++-
.../elasticsearch/impl/ElasticsearchSourceStage.scala | 6 +++++-
.../test/scala/docs/scaladsl/ElasticsearchSpecUtils.scala | 6 +++++-
.../src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala | 10 ++++++++--
.../src/test/scala/docs/scaladsl/OpensearchV1Spec.scala | 9 +++++++--
.../pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala | 9 ++++++++-
.../src/test/scala/docs/scaladsl/ExampleReader.scala | 5 ++++-
.../bigquery/storage/scaladsl/BigQueryAvroStorageSpec.scala | 4 +++-
.../bigquery/storage/scaladsl/BigQueryStorageSpec.scala | 4 +++-
.../stream/connectors/googlecloud/bigquery/BigQueryExt.scala | 7 ++++++-
.../connectors/googlecloud/bigquery/javadsl/BigQuery.scala | 4 +++-
.../googlecloud/bigquery/scaladsl/BigQueryJobs.scala | 5 ++++-
.../googlecloud/bigquery/scaladsl/BigQueryTableData.scala | 5 ++++-
.../googlecloud/bigquery/scaladsl/schema/BasicSchemas.scala | 6 +++++-
.../bigquery/scaladsl/schema/JavaTimeSchemas.scala | 5 ++++-
.../bigquery/scaladsl/schema/PrimitiveSchemaWriter.scala | 4 +++-
.../googlecloud/bigquery/scaladsl/schema/SchemaWriter.scala | 4 +++-
.../src/test/scala/docs/scaladsl/BigQueryDoc.scala | 9 ++++++++-
.../googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala | 7 ++++++-
.../googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala | 7 ++++++-
.../googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala | 7 ++++++-
.../googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala | 7 ++++++-
.../apache/pekko/stream/connectors/google/GoogleExt.scala | 7 ++++++-
.../stream/connectors/huawei/pushkit/HmsSettingExt.scala | 7 ++++++-
.../pekko/stream/connectors/ironmq/javadsl/package.scala | 3 ++-
.../stream/connectors/kinesis/scaladsl/KinesisFlow.scala | 5 ++++-
.../connectors/kinesis/scaladsl/KinesisSchedulerSource.scala | 4 +++-
.../connectors/kinesis/KinesisSchedulerSourceSpec.scala | 4 +++-
.../pekko/stream/connectors/mongodb/javadsl/MongoFlow.scala | 6 +++++-
.../pekko/stream/connectors/mongodb/javadsl/MongoSink.scala | 6 +++++-
.../pekko/stream/connectors/mongodb/scaladsl/MongoSink.scala | 6 +++++-
.../connectors/mqtt/streaming/javadsl/MqttSession.scala | 6 ++++--
.../src/test/scala/docs/scaladsl/MqttSessionSpec.scala | 5 ++++-
.../pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala | 12 ++++++++++--
orientdb/src/test/scala/docs/scaladsl/OrientDbSpec.scala | 5 ++++-
.../stream/connectors/pravega/impl/PravegaTableSource.scala | 5 ++++-
.../src/test/scala/docs/scaladsl/PravegaReadWriteDocs.scala | 6 +++++-
.../src/test/scala/docs/scaladsl/PravegaSettingsSpec.scala | 6 +++++-
.../apache/pekko/stream/connectors/reference/Resource.scala | 7 ++++++-
.../stream/connectors/reference/javadsl/Reference.scala | 5 ++++-
.../stream/connectors/reference/scaladsl/Reference.scala | 4 +++-
.../pekko/stream/connectors/s3/impl/HttpRequests.scala | 7 ++++++-
s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala | 5 ++++-
.../pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala | 6 +++++-
.../pekko/stream/connectors/sqs/testkit/MessageFactory.scala | 4 +++-
sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala | 6 +++++-
.../unixdomainsocket/impl/UnixDomainSocketImpl.scala | 4 +++-
56 files changed, 263 insertions(+), 60 deletions(-)
diff --git a/.git-blame-ignore-revs b/.git-blame-ignore-revs
index 7c0fc8430..2c8d251c7 100644
--- a/.git-blame-ignore-revs
+++ b/.git-blame-ignore-revs
@@ -20,3 +20,6 @@ f777a66544eb2a5230be19990ff3a9befa2efbe4
# Scala Steward: Reformat with scalafmt 3.10.4
a48798d831f196b38e4c3e4a6e4ce958b647fb51
+
+# Scala Steward: Reformat with scalafmt 3.10.5
+40bee180a75b1ebe82267623090fe1fb934b40ae
diff --git a/.scalafmt.conf b/.scalafmt.conf
index 78887b58b..958e75f90 100644
--- a/.scalafmt.conf
+++ b/.scalafmt.conf
@@ -1,4 +1,4 @@
-version = 3.10.4
+version = 3.10.5
runner.dialect = scala213
project.git = true
style = defaultWithAlign
diff --git
a/amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpGraphStageLogicConnectionShutdownSpec.scala
b/amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpGraphStageLogicConnectionShutdownSpec.scala
index 743581bc5..ae249678f 100644
---
a/amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpGraphStageLogicConnectionShutdownSpec.scala
+++
b/amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpGraphStageLogicConnectionShutdownSpec.scala
@@ -19,7 +19,10 @@ import java.util.concurrent.atomic.AtomicInteger
import org.apache.pekko
import pekko.actor.ActorSystem
import pekko.stream.connectors.amqp.{
- AmqpCachedConnectionProvider, AmqpConnectionFactoryConnectionProvider,
AmqpProxyConnection, AmqpWriteSettings,
+ AmqpCachedConnectionProvider,
+ AmqpConnectionFactoryConnectionProvider,
+ AmqpProxyConnection,
+ AmqpWriteSettings,
QueueDeclaration
}
import pekko.stream.connectors.testkit.scaladsl.LogCapturing
diff --git
a/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/TestBase.scala
b/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/TestBase.scala
index baff80bea..d0494ad9a 100644
---
a/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/TestBase.scala
+++
b/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/TestBase.scala
@@ -18,7 +18,9 @@
package org.apache.pekko.stream.connectors.awsspi
import software.amazon.awssdk.auth.credentials.{
- AwsCredentialsProviderChain, EnvironmentVariableCredentialsProvider,
ProfileCredentialsProvider,
+ AwsCredentialsProviderChain,
+ EnvironmentVariableCredentialsProvider,
+ ProfileCredentialsProvider,
SystemPropertyCredentialsProvider
}
import software.amazon.awssdk.regions.Region
diff --git
a/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala
b/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala
index c986c79e0..4aa7f562e 100644
---
a/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala
+++
b/aws-spi-pekko-http-int-tests/src/test/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala
@@ -23,7 +23,10 @@ import org.scalatest.wordspec.AnyWordSpec
import org.scalatest.matchers.should.Matchers
import software.amazon.awssdk.services.sqs.SqsAsyncClient
import software.amazon.awssdk.services.sqs.model.{
- CreateQueueRequest, DeleteQueueRequest, ReceiveMessageRequest,
SendMessageRequest
+ CreateQueueRequest,
+ DeleteQueueRequest,
+ ReceiveMessageRequest,
+ SendMessageRequest
}
import scala.util.Random
diff --git a/cassandra/src/test/scala/docs/scaladsl/CassandraFlowSpec.scala
b/cassandra/src/test/scala/docs/scaladsl/CassandraFlowSpec.scala
index 11ad2b151..3ba096514 100644
--- a/cassandra/src/test/scala/docs/scaladsl/CassandraFlowSpec.scala
+++ b/cassandra/src/test/scala/docs/scaladsl/CassandraFlowSpec.scala
@@ -18,7 +18,10 @@ import pekko.{ Done, NotUsed }
import pekko.actor.ActorSystem
import pekko.stream.connectors.cassandra.{ CassandraSessionSettings,
CassandraWriteSettings }
import pekko.stream.connectors.cassandra.scaladsl.{
- CassandraFlow, CassandraSession, CassandraSource, CassandraSpecBase
+ CassandraFlow,
+ CassandraSession,
+ CassandraSource,
+ CassandraSpecBase
}
import pekko.stream.scaladsl.{ Sink, Source, SourceWithContext }
import pekko.stream.testkit.scaladsl.StreamTestKit.assertAllStagesStopped
diff --git
a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseFlow.scala
b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseFlow.scala
index 525d8d1e2..aa267cdab 100644
---
a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseFlow.scala
+++
b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseFlow.scala
@@ -16,7 +16,11 @@ package org.apache.pekko.stream.connectors.couchbase.javadsl
import org.apache.pekko
import pekko.NotUsed
import pekko.stream.connectors.couchbase.{
- scaladsl, CouchbaseDeleteResult, CouchbaseSessionSettings,
CouchbaseWriteResult, CouchbaseWriteSettings
+ scaladsl,
+ CouchbaseDeleteResult,
+ CouchbaseSessionSettings,
+ CouchbaseWriteResult,
+ CouchbaseWriteSettings
}
import pekko.stream.javadsl.Flow
import com.couchbase.client.java.document.{ Document, JsonDocument }
diff --git
a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala
b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala
index 823595c07..ad35b1cee 100644
---
a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala
+++
b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala
@@ -16,8 +16,15 @@ package org.apache.pekko.stream.connectors.couchbase.scaladsl
import org.apache.pekko
import pekko.NotUsed
import pekko.stream.connectors.couchbase.{
- CouchbaseDeleteFailure, CouchbaseDeleteResult, CouchbaseDeleteSuccess,
CouchbaseSessionRegistry,
- CouchbaseSessionSettings, CouchbaseWriteFailure, CouchbaseWriteResult,
CouchbaseWriteSettings, CouchbaseWriteSuccess
+ CouchbaseDeleteFailure,
+ CouchbaseDeleteResult,
+ CouchbaseDeleteSuccess,
+ CouchbaseSessionRegistry,
+ CouchbaseSessionSettings,
+ CouchbaseWriteFailure,
+ CouchbaseWriteResult,
+ CouchbaseWriteSettings,
+ CouchbaseWriteSuccess
}
import pekko.stream.scaladsl.Flow
import com.couchbase.client.java.document.{ Document, JsonDocument }
diff --git a/couchbase/src/test/scala/docs/scaladsl/CouchbaseFlowSpec.scala
b/couchbase/src/test/scala/docs/scaladsl/CouchbaseFlowSpec.scala
index 8bb7dd6f2..95254c2d7 100644
--- a/couchbase/src/test/scala/docs/scaladsl/CouchbaseFlowSpec.scala
+++ b/couchbase/src/test/scala/docs/scaladsl/CouchbaseFlowSpec.scala
@@ -16,7 +16,11 @@ package docs.scaladsl
import org.apache.pekko
import pekko.Done
import pekko.stream.connectors.couchbase.{
- CouchbaseDeleteFailure, CouchbaseDeleteResult, CouchbaseWriteFailure,
CouchbaseWriteResult, CouchbaseWriteSettings
+ CouchbaseDeleteFailure,
+ CouchbaseDeleteResult,
+ CouchbaseWriteFailure,
+ CouchbaseWriteResult,
+ CouchbaseWriteSettings
}
import pekko.stream.connectors.couchbase.scaladsl.CouchbaseFlow
import pekko.stream.connectors.couchbase.testing.{ CouchbaseSupport,
TestObject }
diff --git
a/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala
b/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala
index 629a2266c..6b69fcd58 100644
---
a/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala
+++
b/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala
@@ -20,7 +20,10 @@ import software.amazon.awssdk.core.async.SdkPublisher
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient
import software.amazon.awssdk.services.dynamodb.model._
import software.amazon.awssdk.services.dynamodb.paginators.{
- BatchGetItemPublisher, ListTablesPublisher, QueryPublisher, ScanPublisher
+ BatchGetItemPublisher,
+ ListTablesPublisher,
+ QueryPublisher,
+ ScanPublisher
}
import scala.concurrent.Future
diff --git
a/elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala
b/elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala
index 2d74b8d53..4a4222c2d 100644
---
a/elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala
+++
b/elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala
@@ -20,7 +20,11 @@ import pekko.http.scaladsl.model.Uri.Path
import pekko.http.scaladsl.model._
import pekko.http.scaladsl.unmarshalling.Unmarshal
import pekko.stream.connectors.elasticsearch.{
- ApiVersion, ElasticsearchParams, OpensearchApiVersion, ReadResult,
SourceSettingsBase
+ ApiVersion,
+ ElasticsearchParams,
+ OpensearchApiVersion,
+ ReadResult,
+ SourceSettingsBase
}
import pekko.stream.stage.{ GraphStage, GraphStageLogic, OutHandler,
StageLogging }
import pekko.stream.{ Attributes, Materializer, Outlet, SourceShape }
diff --git
a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchSpecUtils.scala
b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchSpecUtils.scala
index fe8ca901f..2c67de274 100644
--- a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchSpecUtils.scala
+++ b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchSpecUtils.scala
@@ -20,7 +20,11 @@ import pekko.http.scaladsl.model.Uri.Path
import pekko.http.scaladsl.model.{ ContentTypes, HttpMethods, HttpRequest, Uri
}
import pekko.stream.connectors.elasticsearch.scaladsl.ElasticsearchSource
import pekko.stream.connectors.elasticsearch.{
- ApiVersionBase, ElasticsearchConnectionSettings, ElasticsearchParams,
OpensearchApiVersion, OpensearchParams,
+ ApiVersionBase,
+ ElasticsearchConnectionSettings,
+ ElasticsearchParams,
+ OpensearchApiVersion,
+ OpensearchParams,
SourceSettingsBase
}
import pekko.stream.scaladsl.Sink
diff --git
a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
index 731ec0e3b..1b17aff40 100644
--- a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
+++ b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
@@ -18,8 +18,14 @@ import pekko.http.scaladsl.model.{ HttpMethods, HttpRequest,
Uri }
import pekko.http.scaladsl.model.Uri.Path
import pekko.stream.connectors.elasticsearch.scaladsl.{ ElasticsearchFlow,
ElasticsearchSink, ElasticsearchSource }
import pekko.stream.connectors.elasticsearch.{
- ApiVersion, ElasticsearchConnectionSettings, ElasticsearchSourceSettings,
ElasticsearchWriteSettings, ReadResult,
- StringMessageWriter, WriteMessage, WriteResult
+ ApiVersion,
+ ElasticsearchConnectionSettings,
+ ElasticsearchSourceSettings,
+ ElasticsearchWriteSettings,
+ ReadResult,
+ StringMessageWriter,
+ WriteMessage,
+ WriteResult
}
import pekko.stream.scaladsl.{ Sink, Source }
import pekko.testkit.TestKit
diff --git a/elasticsearch/src/test/scala/docs/scaladsl/OpensearchV1Spec.scala
b/elasticsearch/src/test/scala/docs/scaladsl/OpensearchV1Spec.scala
index 6eb3c1111..ba7c5d443 100644
--- a/elasticsearch/src/test/scala/docs/scaladsl/OpensearchV1Spec.scala
+++ b/elasticsearch/src/test/scala/docs/scaladsl/OpensearchV1Spec.scala
@@ -17,8 +17,13 @@ import org.apache.pekko
import pekko.http.scaladsl.model.Uri.Path
import pekko.http.scaladsl.model.{ HttpMethods, HttpRequest, Uri }
import pekko.stream.connectors.elasticsearch.{
- ElasticsearchConnectionSettings, OpensearchApiVersion,
OpensearchConnectionSettings, ReadResult, StringMessageWriter,
- WriteMessage, WriteResult
+ ElasticsearchConnectionSettings,
+ OpensearchApiVersion,
+ OpensearchConnectionSettings,
+ ReadResult,
+ StringMessageWriter,
+ WriteMessage,
+ WriteResult
}
import pekko.stream.connectors.elasticsearch.scaladsl.{ ElasticsearchFlow,
ElasticsearchSink, ElasticsearchSource }
import pekko.stream.connectors.elasticsearch._
diff --git
a/ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala
b/ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala
index 7059632b3..b26f17426 100644
---
a/ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala
+++
b/ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala
@@ -18,7 +18,14 @@ import org.apache.pekko
import pekko.stream.impl.Stages.DefaultAttributes.IODispatcher
import pekko.stream.stage.{ GraphStageWithMaterializedValue, InHandler,
OutHandler }
import pekko.stream.{
- Attributes, IOOperationIncompleteException, IOResult, Inlet, Outlet, Shape,
SinkShape, SourceShape
+ Attributes,
+ IOOperationIncompleteException,
+ IOResult,
+ Inlet,
+ Outlet,
+ Shape,
+ SinkShape,
+ SourceShape
}
import pekko.util.ByteString
import pekko.util.ByteString.ByteString1C
diff --git
a/google-cloud-bigquery-storage/src/test/scala/docs/scaladsl/ExampleReader.scala
b/google-cloud-bigquery-storage/src/test/scala/docs/scaladsl/ExampleReader.scala
index 957343530..92a6d74d6 100644
---
a/google-cloud-bigquery-storage/src/test/scala/docs/scaladsl/ExampleReader.scala
+++
b/google-cloud-bigquery-storage/src/test/scala/docs/scaladsl/ExampleReader.scala
@@ -18,7 +18,10 @@ import pekko.actor.ActorSystem
import pekko.http.scaladsl.unmarshalling.FromByteStringUnmarshaller
import pekko.stream.connectors.googlecloud.bigquery.storage.{ BigQueryRecord,
BigQueryStorageSettings }
import pekko.stream.connectors.googlecloud.bigquery.storage.scaladsl.{
- BigQueryArrowStorage, BigQueryAvroStorage, BigQueryStorageAttributes,
GrpcBigQueryStorageReader
+ BigQueryArrowStorage,
+ BigQueryAvroStorage,
+ BigQueryStorageAttributes,
+ GrpcBigQueryStorageReader
}
import org.scalatestplus.mockito.MockitoSugar.mock
diff --git
a/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorageSpec.scala
b/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorageSpec.scala
index b9f9e125a..326e0997b 100644
---
a/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorageSpec.scala
+++
b/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorageSpec.scala
@@ -16,7 +16,9 @@ package
org.apache.pekko.stream.connectors.googlecloud.bigquery.storage.scaladsl
import org.apache.pekko
import pekko.stream.connectors.googlecloud.bigquery.storage.impl.AvroDecoder
import pekko.stream.connectors.googlecloud.bigquery.storage.{
- BigQueryRecord, BigQueryStorageSettings, BigQueryStorageSpecBase
+ BigQueryRecord,
+ BigQueryStorageSettings,
+ BigQueryStorageSpecBase
}
import pekko.stream.connectors.testkit.scaladsl.LogCapturing
import pekko.stream.scaladsl.Sink
diff --git
a/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageSpec.scala
b/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageSpec.scala
index 53aa9eadb..efff7c244 100644
---
a/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageSpec.scala
+++
b/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageSpec.scala
@@ -16,7 +16,9 @@ package
org.apache.pekko.stream.connectors.googlecloud.bigquery.storage.scaladsl
import org.apache.pekko
import pekko.stream.connectors.googlecloud.bigquery.storage.impl.{
AvroDecoder, SimpleRowReader }
import pekko.stream.connectors.googlecloud.bigquery.storage.{
- BigQueryRecord, BigQueryStorageSettings, BigQueryStorageSpecBase
+ BigQueryRecord,
+ BigQueryStorageSettings,
+ BigQueryStorageSpecBase
}
import pekko.stream.connectors.testkit.scaladsl.LogCapturing
import pekko.stream.scaladsl.Sink
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala
index 32a3dbf1c..61ab2ce1e 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala
@@ -15,7 +15,12 @@ package
org.apache.pekko.stream.connectors.googlecloud.bigquery
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.annotation.InternalApi
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala
index 96329678e..4a19a3b46 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala
@@ -28,7 +28,9 @@ import
pekko.stream.connectors.googlecloud.bigquery.model.Dataset
import pekko.stream.connectors.googlecloud.bigquery.model.{ Job,
JobCancelResponse, JobReference }
import pekko.stream.connectors.googlecloud.bigquery.model.{ QueryRequest,
QueryResponse }
import pekko.stream.connectors.googlecloud.bigquery.model.{
- TableDataInsertAllRequest, TableDataInsertAllResponse, TableDataListResponse
+ TableDataInsertAllRequest,
+ TableDataInsertAllResponse,
+ TableDataListResponse
}
import pekko.stream.connectors.googlecloud.bigquery.model.{ Table,
TableListResponse, TableReference, TableSchema }
import pekko.stream.connectors.googlecloud.bigquery.scaladsl.{ BigQuery =>
ScalaBigQuery }
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala
index 6bd66948d..c6ea7b12f 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala
@@ -31,7 +31,10 @@ import pekko.stream.connectors.googlecloud.bigquery._
import
pekko.stream.connectors.googlecloud.bigquery.model.CreateDisposition.CreateNever
import
pekko.stream.connectors.googlecloud.bigquery.model.SourceFormat.NewlineDelimitedJsonFormat
import pekko.stream.connectors.googlecloud.bigquery.model.{
- Job, JobCancelResponse, JobConfiguration, JobConfigurationLoad
+ Job,
+ JobCancelResponse,
+ JobConfiguration,
+ JobConfigurationLoad
}
import pekko.stream.connectors.googlecloud.bigquery.model.TableReference
import
pekko.stream.connectors.googlecloud.bigquery.model.WriteDisposition.WriteAppend
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala
index 35b5ad754..8fb9680b5 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala
@@ -26,7 +26,10 @@ import pekko.stream.connectors.google.{ GoogleAttributes,
GoogleSettings }
import pekko.stream.connectors.google.http.GoogleHttp
import pekko.stream.connectors.google.implicits._
import pekko.stream.connectors.googlecloud.bigquery.model.{
- Row, TableDataInsertAllRequest, TableDataInsertAllResponse,
TableDataListResponse
+ Row,
+ TableDataInsertAllRequest,
+ TableDataInsertAllResponse,
+ TableDataListResponse
}
import pekko.stream.connectors.googlecloud.bigquery.{ BigQueryEndpoints,
BigQueryException, InsertAllRetryPolicy }
import pekko.stream.scaladsl.{ Flow, Keep, Sink, Source }
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BasicSchemas.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BasicSchemas.scala
index c816a3aee..6961cbe4a 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BasicSchemas.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BasicSchemas.scala
@@ -14,7 +14,11 @@
package org.apache.pekko.stream.connectors.googlecloud.bigquery.scaladsl.schema
import
org.apache.pekko.stream.connectors.googlecloud.bigquery.model.TableFieldSchemaType.{
- Boolean, Float, Integer, Numeric, String
+ Boolean,
+ Float,
+ Integer,
+ Numeric,
+ String
}
/**
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/JavaTimeSchemas.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/JavaTimeSchemas.scala
index 262ddadeb..48631efc2 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/JavaTimeSchemas.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/JavaTimeSchemas.scala
@@ -14,7 +14,10 @@
package org.apache.pekko.stream.connectors.googlecloud.bigquery.scaladsl.schema
import
org.apache.pekko.stream.connectors.googlecloud.bigquery.model.TableFieldSchemaType.{
- Date, DateTime, Time, Timestamp
+ Date,
+ DateTime,
+ Time,
+ Timestamp
}
import java.time.{ Instant, LocalDate, LocalDateTime, LocalTime }
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/PrimitiveSchemaWriter.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/PrimitiveSchemaWriter.scala
index 6dd44c931..b4c469b16 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/PrimitiveSchemaWriter.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/PrimitiveSchemaWriter.scala
@@ -14,7 +14,9 @@
package org.apache.pekko.stream.connectors.googlecloud.bigquery.scaladsl.schema
import org.apache.pekko.stream.connectors.googlecloud.bigquery.model.{
- TableFieldSchema, TableFieldSchemaMode, TableFieldSchemaType
+ TableFieldSchema,
+ TableFieldSchemaMode,
+ TableFieldSchemaType
}
private[schema] final class PrimitiveSchemaWriter[T](`type`:
TableFieldSchemaType) extends SchemaWriter[T] {
diff --git
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/SchemaWriter.scala
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/SchemaWriter.scala
index 0bf586806..70194bf34 100644
---
a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/SchemaWriter.scala
+++
b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/SchemaWriter.scala
@@ -14,7 +14,9 @@
package org.apache.pekko.stream.connectors.googlecloud.bigquery.scaladsl.schema
import org.apache.pekko.stream.connectors.googlecloud.bigquery.model.{
- TableFieldSchema, TableFieldSchemaMode, TableSchema
+ TableFieldSchema,
+ TableFieldSchemaMode,
+ TableSchema
}
import scala.annotation.implicitNotFound
diff --git
a/google-cloud-bigquery/src/test/scala/docs/scaladsl/BigQueryDoc.scala
b/google-cloud-bigquery/src/test/scala/docs/scaladsl/BigQueryDoc.scala
index fa5f270c1..2c71e35e2 100644
--- a/google-cloud-bigquery/src/test/scala/docs/scaladsl/BigQueryDoc.scala
+++ b/google-cloud-bigquery/src/test/scala/docs/scaladsl/BigQueryDoc.scala
@@ -19,7 +19,14 @@ import
pekko.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._
import pekko.stream.connectors.google.{ GoogleAttributes, GoogleSettings }
import pekko.stream.connectors.googlecloud.bigquery.InsertAllRetryPolicy
import pekko.stream.connectors.googlecloud.bigquery.model.{
- Dataset, Job, JobReference, JobState, QueryResponse, Table,
TableDataListResponse, TableListResponse
+ Dataset,
+ Job,
+ JobReference,
+ JobState,
+ QueryResponse,
+ Table,
+ TableDataListResponse,
+ TableListResponse
}
import
pekko.stream.connectors.googlecloud.bigquery.scaladsl.schema.BigQuerySchemas._
import
pekko.stream.connectors.googlecloud.bigquery.scaladsl.schema.TableSchemaWriter
diff --git
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala
index 8b6e33aca..9fd70656a 100644
---
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala
+++
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala
@@ -15,7 +15,12 @@ package
org.apache.pekko.stream.connectors.googlecloud.pubsub.grpc.javadsl
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.annotation.ApiMayChange
import pekko.stream.connectors.google.GoogleSettings
diff --git
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala
index ac798c346..de2e738ad 100644
---
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala
+++
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala
@@ -15,7 +15,12 @@ package
org.apache.pekko.stream.connectors.googlecloud.pubsub.grpc.javadsl
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.annotation.ApiMayChange
import pekko.stream.connectors.google.GoogleSettings
diff --git
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala
index f84bf2055..286c6d78e 100644
---
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala
+++
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala
@@ -15,7 +15,12 @@ package
org.apache.pekko.stream.connectors.googlecloud.pubsub.grpc.scaladsl
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.annotation.ApiMayChange
import pekko.stream.connectors.google.GoogleSettings
diff --git
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala
index a47f8ce0e..0d70d861d 100644
---
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala
+++
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala
@@ -15,7 +15,12 @@ package
org.apache.pekko.stream.connectors.googlecloud.pubsub.grpc.scaladsl
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.annotation.ApiMayChange
import pekko.stream.connectors.google.GoogleSettings
diff --git
a/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala
b/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala
index 179a7318d..bb6680a89 100644
---
a/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala
+++
b/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala
@@ -15,7 +15,12 @@ package org.apache.pekko.stream.connectors.google
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.annotation.InternalApi
diff --git
a/huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala
b/huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala
index 9c03fd920..019e6d2d4 100644
---
a/huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala
+++
b/huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala
@@ -15,7 +15,12 @@ package org.apache.pekko.stream.connectors.huawei.pushkit
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.annotation.InternalApi
diff --git
a/ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/package.scala
b/ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/package.scala
index 50fbaf540..93d40b731 100644
---
a/ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/package.scala
+++
b/ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/package.scala
@@ -18,7 +18,8 @@ import java.util.concurrent.CompletionStage
import org.apache.pekko
import pekko.Done
import pekko.stream.connectors.ironmq.scaladsl.{
- Committable => ScalaCommittable, CommittableMessage =>
ScalaCommittableMessage
+ Committable => ScalaCommittable,
+ CommittableMessage => ScalaCommittableMessage
}
import scala.concurrent.Future
diff --git
a/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala
b/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala
index 9a52bebfc..16efc29f9 100644
---
a/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala
+++
b/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala
@@ -25,7 +25,10 @@ import pekko.util.ByteString
import software.amazon.awssdk.core.SdkBytes
import software.amazon.awssdk.services.kinesis.KinesisAsyncClient
import software.amazon.awssdk.services.kinesis.model.{
- PutRecordsRequest, PutRecordsRequestEntry, PutRecordsResponse,
PutRecordsResultEntry
+ PutRecordsRequest,
+ PutRecordsRequestEntry,
+ PutRecordsResponse,
+ PutRecordsResultEntry
}
import scala.collection.immutable.Queue
diff --git
a/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSchedulerSource.scala
b/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSchedulerSource.scala
index 1f028c359..019769dba 100644
---
a/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSchedulerSource.scala
+++
b/kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSchedulerSource.scala
@@ -18,7 +18,9 @@ import pekko.NotUsed
import pekko.stream._
import pekko.stream.connectors.kinesis.impl.KinesisSchedulerSourceStage
import pekko.stream.connectors.kinesis.{
- CommittableRecord, KinesisSchedulerCheckpointSettings,
KinesisSchedulerSourceSettings
+ CommittableRecord,
+ KinesisSchedulerCheckpointSettings,
+ KinesisSchedulerSourceSettings
}
import pekko.stream.scaladsl.{ Flow, RunnableGraph, Sink, Source, SubFlow }
import software.amazon.kinesis.coordinator.Scheduler
diff --git
a/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala
b/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala
index b77b6ddb9..7dab718c0 100644
---
a/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala
+++
b/kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala
@@ -40,7 +40,9 @@ import software.amazon.kinesis.coordinator.Scheduler
import software.amazon.kinesis.lifecycle.ShutdownReason
import software.amazon.kinesis.lifecycle.events.{ InitializationInput,
ProcessRecordsInput, ShardEndedInput }
import software.amazon.kinesis.processor.{
- RecordProcessorCheckpointer, ShardRecordProcessor,
ShardRecordProcessorFactory
+ RecordProcessorCheckpointer,
+ ShardRecordProcessor,
+ ShardRecordProcessorFactory
}
import software.amazon.kinesis.retrieval.KinesisClientRecord
import software.amazon.kinesis.retrieval.kpl.ExtendedSequenceNumber
diff --git
a/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoFlow.scala
b/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoFlow.scala
index 447281202..a5d67ccf6 100644
---
a/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoFlow.scala
+++
b/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoFlow.scala
@@ -17,7 +17,11 @@ import org.apache.pekko
import pekko.NotUsed
import pekko.stream.connectors.mongodb.{ scaladsl, DocumentReplace,
DocumentUpdate }
import pekko.stream.connectors.mongodb.scaladsl.MongoFlow.{
- DefaultDeleteOptions, DefaultInsertManyOptions, DefaultInsertOneOptions,
DefaultReplaceOptions, DefaultUpdateOptions
+ DefaultDeleteOptions,
+ DefaultInsertManyOptions,
+ DefaultInsertOneOptions,
+ DefaultReplaceOptions,
+ DefaultUpdateOptions
}
import pekko.stream.javadsl.Flow
import com.mongodb.client.model.{ DeleteOptions, InsertManyOptions,
InsertOneOptions, ReplaceOptions, UpdateOptions }
diff --git
a/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSink.scala
b/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSink.scala
index 1a68f5120..9d7cbeb77 100644
---
a/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSink.scala
+++
b/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSink.scala
@@ -19,7 +19,11 @@ import org.apache.pekko
import pekko.{ Done, NotUsed }
import pekko.stream.connectors.mongodb.{ DocumentReplace, DocumentUpdate }
import pekko.stream.connectors.mongodb.scaladsl.MongoFlow.{
- DefaultDeleteOptions, DefaultInsertManyOptions, DefaultInsertOneOptions,
DefaultReplaceOptions, DefaultUpdateOptions
+ DefaultDeleteOptions,
+ DefaultInsertManyOptions,
+ DefaultInsertOneOptions,
+ DefaultReplaceOptions,
+ DefaultUpdateOptions
}
import pekko.stream.javadsl.{ Keep, Sink }
import com.mongodb.client.model.{ DeleteOptions, InsertManyOptions,
InsertOneOptions, ReplaceOptions, UpdateOptions }
diff --git
a/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoSink.scala
b/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoSink.scala
index 0d172a592..6822b7deb 100644
---
a/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoSink.scala
+++
b/mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoSink.scala
@@ -18,7 +18,11 @@ import pekko.stream.scaladsl.{ Keep, Sink }
import pekko.Done
import pekko.stream.connectors.mongodb.{ DocumentReplace, DocumentUpdate }
import pekko.stream.connectors.mongodb.scaladsl.MongoFlow.{
- DefaultDeleteOptions, DefaultInsertManyOptions, DefaultInsertOneOptions,
DefaultReplaceOptions, DefaultUpdateOptions
+ DefaultDeleteOptions,
+ DefaultInsertManyOptions,
+ DefaultInsertOneOptions,
+ DefaultReplaceOptions,
+ DefaultUpdateOptions
}
import com.mongodb.client.model.{ DeleteOptions, InsertManyOptions,
InsertOneOptions, ReplaceOptions, UpdateOptions }
import com.mongodb.reactivestreams.client.MongoCollection
diff --git
a/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/javadsl/MqttSession.scala
b/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/javadsl/MqttSession.scala
index 323c4e0cf..5b537f4ad 100644
---
a/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/javadsl/MqttSession.scala
+++
b/mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/javadsl/MqttSession.scala
@@ -18,8 +18,10 @@ import org.apache.pekko
import pekko.NotUsed
import pekko.actor.ClassicActorSystemProvider
import pekko.stream.connectors.mqtt.streaming.scaladsl.{
- ActorMqttClientSession => ScalaActorMqttClientSession,
ActorMqttServerSession => ScalaActorMqttServerSession,
- MqttClientSession => ScalaMqttClientSession, MqttServerSession =>
ScalaMqttServerSession
+ ActorMqttClientSession => ScalaActorMqttClientSession,
+ ActorMqttServerSession => ScalaActorMqttServerSession,
+ MqttClientSession => ScalaMqttClientSession,
+ MqttServerSession => ScalaMqttServerSession
}
import pekko.stream.javadsl.Source
diff --git a/mqtt-streaming/src/test/scala/docs/scaladsl/MqttSessionSpec.scala
b/mqtt-streaming/src/test/scala/docs/scaladsl/MqttSessionSpec.scala
index 87e5be81c..428f138cd 100644
--- a/mqtt-streaming/src/test/scala/docs/scaladsl/MqttSessionSpec.scala
+++ b/mqtt-streaming/src/test/scala/docs/scaladsl/MqttSessionSpec.scala
@@ -19,7 +19,10 @@ import pekko.actor.ActorSystem
import pekko.pattern.ask
import pekko.stream.connectors.mqtt.streaming._
import pekko.stream.connectors.mqtt.streaming.scaladsl.{
- ActorMqttClientSession, ActorMqttServerSession, Mqtt, MqttServerSession
+ ActorMqttClientSession,
+ ActorMqttServerSession,
+ Mqtt,
+ MqttServerSession
}
import pekko.stream.connectors.testkit.scaladsl.LogCapturing
import pekko.stream.scaladsl.{ BroadcastHub, Flow, Keep, Sink, Source,
SourceQueueWithComplete }
diff --git
a/mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala
b/mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala
index dc7c787f8..9abd66c94 100644
---
a/mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala
+++
b/mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala
@@ -27,8 +27,16 @@ import pekko.stream.stage._
import pekko.util.ByteString
import org.eclipse.paho.client.mqttv3.{
- DisconnectedBufferOptions, IMqttActionListener, IMqttAsyncClient,
IMqttDeliveryToken, IMqttToken, MqttAsyncClient,
- MqttCallbackExtended, MqttConnectOptions, MqttException, MqttMessage =>
PahoMqttMessage
+ DisconnectedBufferOptions,
+ IMqttActionListener,
+ IMqttAsyncClient,
+ IMqttDeliveryToken,
+ IMqttToken,
+ MqttAsyncClient,
+ MqttCallbackExtended,
+ MqttConnectOptions,
+ MqttException,
+ MqttMessage => PahoMqttMessage
}
import scala.collection.mutable
diff --git a/orientdb/src/test/scala/docs/scaladsl/OrientDbSpec.scala
b/orientdb/src/test/scala/docs/scaladsl/OrientDbSpec.scala
index 753541ccc..f4dff41f9 100644
--- a/orientdb/src/test/scala/docs/scaladsl/OrientDbSpec.scala
+++ b/orientdb/src/test/scala/docs/scaladsl/OrientDbSpec.scala
@@ -18,7 +18,10 @@ import pekko.Done
import pekko.actor.ActorSystem
import pekko.stream.connectors.orientdb.scaladsl._
import pekko.stream.connectors.orientdb.{
- OrientDbReadResult, OrientDbSourceSettings, OrientDbWriteMessage,
OrientDbWriteSettings
+ OrientDbReadResult,
+ OrientDbSourceSettings,
+ OrientDbWriteMessage,
+ OrientDbWriteSettings
}
import pekko.stream.connectors.testkit.scaladsl.LogCapturing
import pekko.stream.scaladsl.{ Sink, Source }
diff --git
a/pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableSource.scala
b/pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableSource.scala
index ac51e4c46..e5d6ed852 100644
---
a/pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableSource.scala
+++
b/pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableSource.scala
@@ -28,7 +28,10 @@ import pekko.stream.ActorAttributes
import pekko.stream.connectors.pravega.TableReaderSettings
import io.pravega.client.KeyValueTableFactory
import io.pravega.client.tables.{
- IteratorItem, KeyValueTable, KeyValueTableClientConfiguration, TableEntry =>
JTableEntry
+ IteratorItem,
+ KeyValueTable,
+ KeyValueTableClientConfiguration,
+ TableEntry => JTableEntry
}
import pekko.stream.connectors.pravega.TableEntry
diff --git a/pravega/src/test/scala/docs/scaladsl/PravegaReadWriteDocs.scala
b/pravega/src/test/scala/docs/scaladsl/PravegaReadWriteDocs.scala
index e21626d92..6be579e03 100644
--- a/pravega/src/test/scala/docs/scaladsl/PravegaReadWriteDocs.scala
+++ b/pravega/src/test/scala/docs/scaladsl/PravegaReadWriteDocs.scala
@@ -16,7 +16,11 @@ package docs.scaladsl
import org.apache.pekko
import pekko.actor.ActorSystem
import pekko.stream.connectors.pravega.{
- PravegaEvent, ReaderSettingsBuilder, TableReaderSettingsBuilder,
TableWriterSettings, TableWriterSettingsBuilder,
+ PravegaEvent,
+ ReaderSettingsBuilder,
+ TableReaderSettingsBuilder,
+ TableWriterSettings,
+ TableWriterSettingsBuilder,
WriterSettingsBuilder
}
import pekko.stream.scaladsl.{ Sink, Source }
diff --git a/pravega/src/test/scala/docs/scaladsl/PravegaSettingsSpec.scala
b/pravega/src/test/scala/docs/scaladsl/PravegaSettingsSpec.scala
index 8c7746faf..b109878c9 100644
--- a/pravega/src/test/scala/docs/scaladsl/PravegaSettingsSpec.scala
+++ b/pravega/src/test/scala/docs/scaladsl/PravegaSettingsSpec.scala
@@ -15,7 +15,11 @@ package docs.scaladsl
import java.net.URI
import org.apache.pekko.stream.connectors.pravega.{
- PravegaBaseSpec, ReaderSettingsBuilder, TableReaderSettingsBuilder,
TableWriterSettingsBuilder, WriterSettingsBuilder
+ PravegaBaseSpec,
+ ReaderSettingsBuilder,
+ TableReaderSettingsBuilder,
+ TableWriterSettingsBuilder,
+ WriterSettingsBuilder
}
import io.pravega.client.stream.Serializer
import io.pravega.client.stream.impl.UTF8StringSerializer
diff --git
a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala
b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala
index 32f5ba45b..461fbe92f 100644
---
a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala
+++
b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala
@@ -15,7 +15,12 @@ package org.apache.pekko.stream.connectors.reference
import org.apache.pekko
import pekko.actor.{
- ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension,
ExtensionId, ExtensionIdProvider
+ ActorSystem,
+ ClassicActorSystemProvider,
+ ExtendedActorSystem,
+ Extension,
+ ExtensionId,
+ ExtensionIdProvider
}
import pekko.stream.scaladsl.Flow
import pekko.util.ByteString
diff --git
a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/javadsl/Reference.scala
b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/javadsl/Reference.scala
index a6475bb50..8a430b6db 100644
---
a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/javadsl/Reference.scala
+++
b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/javadsl/Reference.scala
@@ -19,7 +19,10 @@ import org.apache.pekko
import pekko.{ Done, NotUsed }
import pekko.stream.connectors.reference.scaladsl
import pekko.stream.connectors.reference.{
- ReferenceReadResult, ReferenceWriteMessage, ReferenceWriteResult,
SourceSettings
+ ReferenceReadResult,
+ ReferenceWriteMessage,
+ ReferenceWriteResult,
+ SourceSettings
}
import pekko.stream.javadsl.{ Flow, Source }
diff --git
a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/scaladsl/Reference.scala
b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/scaladsl/Reference.scala
index e9521a451..646b84444 100644
---
a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/scaladsl/Reference.scala
+++
b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/scaladsl/Reference.scala
@@ -18,7 +18,9 @@ import pekko.actor.ActorSystem
import pekko.stream.Attributes
import pekko.{ Done, NotUsed }
import pekko.stream.connectors.reference.impl.{
- ReferenceFlowStage, ReferenceSourceStage, ReferenceWithResourceFlowStage
+ ReferenceFlowStage,
+ ReferenceSourceStage,
+ ReferenceWithResourceFlowStage
}
import pekko.stream.connectors.reference._
import pekko.stream.scaladsl.{ Flow, Source }
diff --git
a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala
b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala
index e9622ca20..e3d489738 100644
---
a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala
+++
b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala
@@ -25,7 +25,12 @@ import pekko.http.scaladsl.model.headers.{
`Raw-Request-URI`, Host, RawHeader }
import pekko.http.scaladsl.model.{ RequestEntity, _ }
import pekko.stream.connectors.s3.AccessStyle.{ PathAccessStyle,
VirtualHostAccessStyle }
import pekko.stream.connectors.s3.{
- ApiVersion, BucketVersioning, BucketVersioningStatus, MFAStatus,
MultipartUpload, S3Settings
+ ApiVersion,
+ BucketVersioning,
+ BucketVersioningStatus,
+ MFAStatus,
+ MultipartUpload,
+ S3Settings
}
import pekko.stream.scaladsl.Source
import pekko.util.ByteString
diff --git a/s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala
b/s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala
index 897b294a5..de669ee75 100644
--- a/s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala
+++ b/s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala
@@ -22,7 +22,10 @@ import pekko.stream.connectors.s3._
import pekko.stream.scaladsl.{ Sink, Source }
import pekko.util.ByteString
import com.github.tomakehurst.wiremock.client.WireMock.{
- headRequestedFor, postRequestedFor, putRequestedFor, urlEqualTo
+ headRequestedFor,
+ postRequestedFor,
+ putRequestedFor,
+ urlEqualTo
}
import com.github.tomakehurst.wiremock.http.Fault
import com.github.tomakehurst.wiremock.matching.EqualToPattern
diff --git
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
index c5b32b12e..902f1dbf9 100644
---
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
+++
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
@@ -17,7 +17,11 @@ import org.apache.pekko
import pekko.NotUsed
import pekko.annotation.ApiMayChange
import pekko.stream.connectors.sqs.{
- SqsPublishBatchSettings, SqsPublishGroupedSettings, SqsPublishResult,
SqsPublishResultEntry, SqsPublishSettings
+ SqsPublishBatchSettings,
+ SqsPublishGroupedSettings,
+ SqsPublishResult,
+ SqsPublishResultEntry,
+ SqsPublishSettings
}
import pekko.stream.javadsl.Flow
import pekko.stream.scaladsl.{ Flow => SFlow }
diff --git
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/testkit/MessageFactory.scala
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/testkit/MessageFactory.scala
index 2599ec223..6566bdfa8 100644
---
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/testkit/MessageFactory.scala
+++
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/testkit/MessageFactory.scala
@@ -16,7 +16,9 @@ package org.apache.pekko.stream.connectors.sqs.testkit
import org.apache.pekko
import pekko.stream.connectors.sqs.SqsAckResult.{
SqsChangeMessageVisibilityResult, SqsDeleteResult, SqsIgnoreResult }
import pekko.stream.connectors.sqs.SqsAckResultEntry.{
- SqsChangeMessageVisibilityResultEntry, SqsDeleteResultEntry,
SqsIgnoreResultEntry
+ SqsChangeMessageVisibilityResultEntry,
+ SqsDeleteResultEntry,
+ SqsIgnoreResultEntry
}
import pekko.stream.connectors.sqs.{ MessageAction, SqsPublishResult,
SqsPublishResultEntry, SqsResult }
import software.amazon.awssdk.services.sqs.model._
diff --git a/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
b/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
index c71d05dbe..3ec5e4044 100644
--- a/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
+++ b/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
@@ -32,7 +32,11 @@ import software.amazon.awssdk.http.async.SdkAsyncHttpClient
import software.amazon.awssdk.regions.Region
import software.amazon.awssdk.services.sqs.SqsAsyncClient
import software.amazon.awssdk.services.sqs.model.{
- Message, MessageAttributeValue, MessageSystemAttributeName,
QueueDoesNotExistException, SendMessageRequest
+ Message,
+ MessageAttributeValue,
+ MessageSystemAttributeName,
+ QueueDoesNotExistException,
+ SendMessageRequest
}
import scala.collection.immutable
diff --git
a/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala
b/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala
index 212ffb897..b5cbf5bfe 100644
---
a/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala
+++
b/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala
@@ -20,7 +20,9 @@ import pekko.annotation.InternalApi
import pekko.event.{ Logging, LoggingAdapter }
import pekko.stream._
import pekko.stream.connectors.unixdomainsocket.scaladsl.UnixDomainSocket.{
- IncomingConnection, OutgoingConnection, ServerBinding
+ IncomingConnection,
+ OutgoingConnection,
+ ServerBinding
}
import pekko.stream.scaladsl.{ Flow, Keep, Sink, Source,
SourceQueueWithComplete }
import pekko.util.ByteString
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
