This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
from 1f4a25ec7 Update auth, dynamodb, eventbridge, firehose, ... to 2.41.10
(#1370)
new 686a58d41 Update scalafmt-core to 3.10.4
new 2746bf3a9 Reformat with scalafmt 3.10.4
new 1af952746 Add 'Reformat with scalafmt 3.10.4' to .git-blame-ignore-revs
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.git-blame-ignore-revs | 3 ++
.scalafmt.conf | 2 +-
.../connectors/amqp/impl/AmqpRpcFlowStage.scala | 8 +++--
.../test/scala/docs/scaladsl/AmqpDocsSpec.scala | 3 +-
.../amqp/scaladsl/AmqpConnectorsSpec.scala | 6 ++--
...AmqpGraphStageLogicConnectionShutdownSpec.scala | 5 +--
.../pekko/stream/connectors/awsspi/TestBase.scala | 4 +--
.../stream/connectors/awsspi/sqs/SQSITTest.scala | 5 +--
.../test/scala/docs/scaladsl/AzureQueueSpec.scala | 3 +-
build.sbt | 36 ++++++++++++++--------
.../scala/docs/scaladsl/CassandraFlowSpec.scala | 5 +--
.../couchbase/javadsl/CouchbaseFlow.scala | 6 +---
.../couchbase/scaladsl/CouchbaseFlow.scala | 11 ++-----
.../scala/docs/scaladsl/CouchbaseFlowSpec.scala | 6 +---
.../test/scala/docs/scaladsl/CsvToMapSpec.scala | 18 +++++++----
.../stream/connectors/dynamodb/DynamoDbOp.scala | 5 +--
.../pekko/stream/connectors/dynamodb/TestOps.scala | 6 ++--
.../impl/ElasticsearchSourceStage.scala | 19 +++++-------
.../elasticsearch/impl/RestBulkApiV5.scala | 14 ++++-----
.../elasticsearch/impl/RestBulkApiV7.scala | 7 ++---
.../scaladsl/ElasticsearchConnectorBehaviour.scala | 6 ++--
.../docs/scaladsl/ElasticsearchSpecUtils.scala | 6 +---
.../scala/docs/scaladsl/ElasticsearchV5Spec.scala | 19 +++++-------
.../scala/docs/scaladsl/ElasticsearchV7Spec.scala | 9 ++++--
.../scaladsl/OpensearchConnectorBehaviour.scala | 6 ++--
.../scala/docs/scaladsl/OpensearchV1Spec.scala | 18 +++++------
.../file/impl/archive/TarArchiveEntry.scala | 3 +-
.../test/scala/docs/scaladsl/TarArchiveSpec.scala | 3 +-
.../connectors/ftp/impl/FtpIOGraphStage.scala | 9 +-----
.../stream/connectors/ftp/impl/FtpOperations.scala | 3 +-
.../test/scala/docs/scaladsl/ExampleReader.scala | 5 +--
.../storage/scaladsl/BigQueryAvroStorageSpec.scala | 4 +--
.../storage/scaladsl/BigQueryStorageSpec.scala | 4 +--
.../googlecloud/bigquery/BigQueryExt.scala | 7 +----
.../googlecloud/bigquery/javadsl/BigQuery.scala | 4 +--
.../bigquery/scaladsl/BigQueryJobs.scala | 5 +--
.../bigquery/scaladsl/BigQueryTableData.scala | 5 +--
.../bigquery/scaladsl/schema/BasicSchemas.scala | 6 +---
.../bigquery/scaladsl/schema/JavaTimeSchemas.scala | 5 +--
.../scaladsl/schema/PrimitiveSchemaWriter.scala | 4 +--
.../bigquery/scaladsl/schema/SchemaWriter.scala | 4 +--
.../src/test/scala/docs/scaladsl/BigQueryDoc.scala | 9 +-----
.../pubsub/grpc/javadsl/GrpcPublisher.scala | 7 +----
.../pubsub/grpc/javadsl/GrpcSubscriber.scala | 7 +----
.../pubsub/grpc/scaladsl/GrpcPublisher.scala | 7 +----
.../pubsub/grpc/scaladsl/GrpcSubscriber.scala | 7 +----
.../connectors/googlecloud/pubsub/model.scala | 9 ++++--
.../connectors/googlecloud/pubsub/ModelSpec.scala | 18 +++++++----
.../pekko/stream/connectors/google/GoogleExt.scala | 7 +----
.../stream/connectors/google/util/EitherFlow.scala | 3 +-
.../connectors/huawei/pushkit/HmsSettingExt.scala | 7 +----
.../stream/connectors/ironmq/javadsl/package.scala | 3 +-
.../jakartams/ConnectionRetrySettings.scala | 5 +--
.../connectors/jakartams/SendRetrySettings.scala | 5 +--
.../jakartams/impl/JmsMessageReader.scala | 3 +-
.../scaladsl/JmsBufferedAckConnectorsSpec.scala | 3 +-
.../scala/docs/scaladsl/JmsConnectorsSpec.scala | 6 ++--
.../scala/docs/scaladsl/JmsTxConnectorsSpec.scala | 6 ++--
.../jakartams/scaladsl/JmsAckConnectorsSpec.scala | 3 +-
.../connectors/jms/ConnectionRetrySettings.scala | 5 +--
.../stream/connectors/jms/SendRetrySettings.scala | 5 +--
.../connectors/jms/impl/JmsMessageReader.scala | 3 +-
.../scala/docs/scaladsl/JmsConnectorsSpec.scala | 6 ++--
.../scala/docs/scaladsl/JmsTxConnectorsSpec.scala | 6 ++--
.../connectors/kinesis/scaladsl/KinesisFlow.scala | 5 +--
.../kinesis/scaladsl/KinesisSchedulerSource.scala | 4 +--
.../kinesis/KinesisSchedulerSourceSpec.scala | 13 ++++----
.../connectors/kinesis/ShardSettingsSpec.scala | 3 +-
.../connectors/mongodb/javadsl/MongoFlow.scala | 6 +---
.../connectors/mongodb/javadsl/MongoSink.scala | 6 +---
.../connectors/mongodb/scaladsl/MongoSink.scala | 6 +---
.../test/scala/docs/scaladsl/MongoSinkSpec.scala | 6 ++--
.../mqtt/streaming/javadsl/MqttSession.scala | 6 ++--
.../stream/connectors/mqtt/streaming/model.scala | 9 ++----
.../mqtt/streaming/scaladsl/MqttSession.scala | 3 +-
.../test/scala/docs/scaladsl/MqttCodecSpec.scala | 3 +-
.../test/scala/docs/scaladsl/MqttSessionSpec.scala | 11 +++----
.../connectors/mqtt/impl/MqttFlowStage.scala | 12 ++------
.../test/scala/docs/scaladsl/OrientDbSpec.scala | 5 +--
.../pravega/impl/PravegaTableSource.scala | 5 +--
.../scala/docs/scaladsl/PravegaReadWriteDocs.scala | 6 +---
.../scala/docs/scaladsl/PravegaSettingsSpec.scala | 6 +---
project/Common.scala | 14 +++++----
.../stream/connectors/reference/Resource.scala | 7 +----
.../connectors/reference/javadsl/Reference.scala | 5 +--
.../connectors/reference/scaladsl/Reference.scala | 4 +--
.../stream/connectors/s3/impl/HttpRequests.scala | 7 +----
.../stream/connectors/s3/impl/Marshalling.scala | 26 ++++++----------
.../connectors/s3/impl/auth/CanonicalRequest.scala | 3 +-
s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala | 5 +--
.../stream/connectors/s3/S3ExceptionSpec.scala | 9 ++++--
.../stream/connectors/s3/S3SettingsSpec.scala | 9 ++++--
.../connectors/s3/impl/MarshallingSpec.scala | 3 +-
.../connectors/s3/impl/SplitAfterSizeSpec.scala | 3 +-
.../impl/auth/SplitAfterSizeWithContextSpec.scala | 3 +-
.../connectors/s3/scaladsl/S3IntegrationSpec.scala | 6 ++--
.../connectors/sqs/javadsl/SqsPublishFlow.scala | 6 +---
.../connectors/sqs/scaladsl/SqsAckFlow.scala | 6 ++--
.../connectors/sqs/scaladsl/SqsPublishFlow.scala | 3 +-
.../connectors/sqs/testkit/MessageFactory.scala | 4 +--
.../test/scala/docs/scaladsl/SqsPublishSpec.scala | 6 ++--
.../test/scala/docs/scaladsl/SqsSourceSpec.scala | 12 +++-----
.../impl/UnixDomainSocketImpl.scala | 4 +--
103 files changed, 298 insertions(+), 409 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
