This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
from ec5347d6 Artifact rename (#10)
new 54c516e8 Update scalafmt
new 0e9e6bd5 Add .gitattributes to enforce unix line endings
new 433daa5c format source with scalafmt, #12
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:
.gitattributes | 5 +
.scalafmt.conf | 90 +++-
.../alpakka/amqp/AmqpConnectionProvider.scala | 59 ++-
.../alpakka/amqp/AmqpConnectorSettings.scala | 58 +--
.../impl/AbstractAmqpAsyncFlowStageLogic.scala | 41 +-
.../amqp/impl/AbstractAmqpFlowStageLogic.scala | 19 +-
.../alpakka/amqp/impl/AmqpAsyncFlowStage.scala | 61 ++-
.../amqp/impl/AmqpAsyncUnorderedFlowStage.scala | 36 +-
.../alpakka/amqp/impl/AmqpConnectorLogic.scala | 13 +-
.../alpakka/amqp/impl/AmqpReplyToSinkStage.scala | 104 ++--
.../alpakka/amqp/impl/AmqpRpcFlowStage.scala | 326 ++++++-------
.../alpakka/amqp/impl/AmqpSimpleFlowStage.scala | 35 +-
.../stream/alpakka/amqp/impl/AmqpSourceStage.scala | 29 +-
.../stream/alpakka/amqp/javadsl/AmqpFlow.scala | 16 +-
.../alpakka/amqp/javadsl/AmqpFlowWithContext.scala | 8 +-
.../stream/alpakka/amqp/javadsl/AmqpRpcFlow.scala | 11 +-
.../stream/alpakka/amqp/javadsl/AmqpSink.scala | 3 +-
.../stream/alpakka/amqp/javadsl/AmqpSource.scala | 2 +-
.../scala/akka/stream/alpakka/amqp/model.scala | 12 +-
.../stream/alpakka/amqp/scaladsl/AmqpFlow.scala | 25 +-
.../amqp/scaladsl/AmqpFlowWithContext.scala | 14 +-
.../stream/alpakka/amqp/scaladsl/AmqpRpcFlow.scala | 10 +-
.../stream/alpakka/amqp/scaladsl/AmqpSink.scala | 2 +-
.../stream/alpakka/amqp/scaladsl/AmqpSource.scala | 2 +-
.../stream/alpakka/amqp/AmqpProxyConnection.scala | 2 +-
.../scaladsl/AmqpConnectionProvidersSpec.scala | 8 +-
.../alpakka/amqp/scaladsl/AmqpConnectorsSpec.scala | 74 +--
.../alpakka/amqp/scaladsl/AmqpFlowSpec.scala | 22 +-
...AmqpGraphStageLogicConnectionShutdownSpec.scala | 5 +-
.../stream/alpakka/amqp/scaladsl/AmqpMocking.scala | 2 +-
.../test/scala/docs/scaladsl/AmqpDocsSpec.scala | 90 ++--
.../alpakka/avroparquet/impl/AvroParquetFlow.scala | 16 +-
.../avroparquet/impl/AvroParquetSource.scala | 7 +-
.../avroparquet/javadsl/AvroParquetSink.scala | 4 +-
.../avroparquet/scaladsl/AvroParquetSink.scala | 2 +-
.../scala/docs/scaladsl/AbstractAvroParquet.scala | 11 +-
.../scala/docs/scaladsl/AvroParquetFlowSpec.scala | 14 +-
.../scala/docs/scaladsl/AvroParquetSinkSpec.scala | 16 +-
.../docs/scaladsl/AvroParquetSourceSpec.scala | 16 +-
.../eventbridge/EventBridgePublishSettings.scala | 2 +-
.../eventbridge/javadsl/EventBridgePublisher.scala | 18 +-
.../scaladsl/EventBridgePublisher.scala | 25 +-
.../aws/eventbridge/DefaultTestContext.scala | 2 +-
.../eventbridge/EventBridgePublishMockSpec.scala | 7 +-
.../aws/eventbridge/IntegrationTestContext.scala | 15 +-
.../docs/scaladsl/EventBridgePublisherSpec.scala | 4 +-
.../alpakka/awslambda/javadsl/AwsLambdaFlow.scala | 2 +-
.../alpakka/awslambda/scaladsl/AwsLambdaFlow.scala | 5 +-
.../scala/docs/scaladsl/AwsLambdaFlowSpec.scala | 16 +-
.../src/test/scala/docs/scaladsl/Examples.scala | 16 +-
.../impl/AzureQueueSinkFunctions.scala | 16 +-
.../storagequeue/impl/AzureQueueSourceStage.scala | 11 +-
.../storagequeue/javadsl/AzureQueueSink.scala | 19 +-
.../storagequeue/javadsl/AzureQueueSource.scala | 2 +-
.../storagequeue/scaladsl/AzureQueueSink.scala | 18 +-
.../storagequeue/scaladsl/AzureQueueSource.scala | 5 +-
.../alpakka/azure/storagequeue/settings.scala | 11 +-
.../test/scala/docs/scaladsl/AzureQueueSpec.scala | 26 +-
build.sbt | 241 ++++-----
.../cassandra/AkkaDiscoverySessionProvider.scala | 15 +-
.../cassandra/CassandraMetricsRegistry.scala | 2 +-
.../cassandra/CassandraSessionSettings.scala | 8 +-
.../alpakka/cassandra/CassandraWriteSettings.scala | 14 +-
.../alpakka/cassandra/CqlSessionProvider.scala | 10 +-
.../alpakka/cassandra/javadsl/CassandraFlow.scala | 34 +-
.../cassandra/javadsl/CassandraSession.scala | 47 +-
.../javadsl/CassandraSessionRegistry.scala | 4 +-
.../cassandra/javadsl/CassandraSource.scala | 2 +-
.../alpakka/cassandra/scaladsl/CassandraFlow.scala | 18 +-
.../cassandra/scaladsl/CassandraSession.scala | 26 +-
.../scaladsl/CassandraSessionRegistry.scala | 22 +-
.../cassandra/scaladsl/CassandraSource.scala | 2 +-
.../cassandra/scaladsl/CassandraLifecycle.scala | 14 +-
.../scaladsl/CassandraSessionPerformanceSpec.scala | 7 +-
.../cassandra/scaladsl/CassandraSpecBase.scala | 4 +-
.../scala/docs/javadsl/CassandraSessionSpec.scala | 14 +-
.../scala/docs/scaladsl/AkkaDiscoverySpec.scala | 2 +-
.../scala/docs/scaladsl/CassandraFlowSpec.scala | 36 +-
.../scala/docs/scaladsl/CassandraSourceSpec.scala | 8 +-
.../couchbase/CouchbaseResponseException.scala | 3 +-
.../couchbase/CouchbaseSessionRegistry.scala | 11 +-
.../couchbase/impl/CouchbaseClusterRegistry.scala | 7 +-
.../couchbase/impl/CouchbaseSessionImpl.scala | 80 ++-
.../impl/CouchbaseSessionJavaAdapter.scala | 19 +-
.../alpakka/couchbase/impl/RxUtilities.scala | 6 +-
.../alpakka/couchbase/javadsl/CouchbaseFlow.scala | 38 +-
.../couchbase/javadsl/CouchbaseSession.scala | 28 +-
.../alpakka/couchbase/javadsl/CouchbaseSink.scala | 26 +-
.../couchbase/javadsl/CouchbaseSource.scala | 12 +-
.../akka/stream/alpakka/couchbase/model.scala | 53 +-
.../alpakka/couchbase/scaladsl/CouchbaseFlow.scala | 132 +++--
.../couchbase/scaladsl/CouchbaseSession.scala | 22 +-
.../alpakka/couchbase/scaladsl/CouchbaseSink.scala | 16 +-
.../couchbase/scaladsl/CouchbaseSource.scala | 12 +-
.../couchbase/scaladsl/DiscoverySupport.scala | 18 +-
.../couchbase/testing/CouchbaseSupport.scala | 18 +-
.../scala/docs/scaladsl/CouchbaseFlowSpec.scala | 167 +++----
.../scaladsl/CouchbaseSessionExamplesSpec.scala | 6 +-
.../scala/docs/scaladsl/CouchbaseSourceSpec.scala | 10 +-
.../test/scala/docs/scaladsl/DiscoverySpec.scala | 10 +-
.../stream/alpakka/csv/scaladsl/CsvBench.scala | 6 +-
.../stream/alpakka/csv/impl/CsvFormatter.scala | 12 +-
.../akka/stream/alpakka/csv/impl/CsvParser.scala | 27 +-
.../stream/alpakka/csv/impl/CsvParsingStage.scala | 25 +-
.../alpakka/csv/impl/CsvToMapJavaStage.scala | 54 +--
.../stream/alpakka/csv/impl/CsvToMapStage.scala | 43 +-
.../alpakka/csv/scaladsl/CsvFormatting.scala | 10 +-
.../stream/alpakka/csv/scaladsl/CsvParsing.scala | 9 +-
.../alpakka/csv/scaladsl/CsvQuotingStyle.scala | 2 +-
.../stream/alpakka/csv/scaladsl/CsvToMap.scala | 67 ++-
.../akka/stream/alpakka/csv/CsvParserSpec.scala | 20 +-
.../scala/docs/scaladsl/CsvFormattingSpec.scala | 9 +-
.../test/scala/docs/scaladsl/CsvParsingSpec.scala | 37 +-
csv/src/test/scala/docs/scaladsl/CsvSpec.scala | 2 +-
.../test/scala/docs/scaladsl/CsvToMapSpec.scala | 107 ++--
.../alpakka/eip/scaladsl/PassThroughExamples.scala | 24 +-
.../akka/stream/alpakka/dynamodb/DynamoDbOp.scala | 6 +-
.../stream/alpakka/dynamodb/javadsl/DynamoDb.scala | 29 +-
.../alpakka/dynamodb/scaladsl/DynamoDb.scala | 34 +-
.../akka/stream/alpakka/dynamodb/ItemSpec.scala | 4 +-
.../akka/stream/alpakka/dynamodb/TableSpec.scala | 4 +-
.../akka/stream/alpakka/dynamodb/TestOps.scala | 48 +-
.../src/test/scala/docs/scaladsl/ExampleSpec.scala | 24 +-
.../src/test/scala/docs/scaladsl/RetrySpec.scala | 8 +-
.../ElasticsearchConnectionSettings.scala | 30 +-
.../ElasticsearchSourceSettings.scala | 49 +-
.../elasticsearch/ElasticsearchWriteSettings.scala | 38 +-
.../elasticsearch/OpensearchSourceSettings.scala | 49 +-
.../elasticsearch/OpensearchWriteSettings.scala | 30 +-
.../stream/alpakka/elasticsearch/ReadResult.scala | 4 +-
.../alpakka/elasticsearch/SourceSettingsBase.scala | 22 +-
.../alpakka/elasticsearch/WriteMessage.scala | 52 +-
.../alpakka/elasticsearch/WriteSettingsBase.scala | 13 +-
.../elasticsearch/impl/ElasticsearchApi.scala | 10 +-
.../impl/ElasticsearchSimpleFlowStage.scala | 35 +-
.../impl/ElasticsearchSourceStage.scala | 61 +--
.../elasticsearch/impl/NDJsonProtocol.scala | 2 +-
.../alpakka/elasticsearch/impl/RestBulkApi.scala | 16 +-
.../alpakka/elasticsearch/impl/RestBulkApiV5.scala | 21 +-
.../alpakka/elasticsearch/impl/RestBulkApiV7.scala | 18 +-
.../elasticsearch/javadsl/ElasticsearchFlow.scala | 35 +-
.../elasticsearch/javadsl/ElasticsearchSink.scala | 5 +-
.../javadsl/ElasticsearchSource.scala | 64 ++-
.../elasticsearch/scaladsl/ElasticsearchFlow.scala | 67 ++-
.../elasticsearch/scaladsl/ElasticsearchSink.scala | 7 +-
.../scaladsl/ElasticsearchSource.scala | 40 +-
.../elasticsearch/testkit/MessageFactory.scala | 26 +-
.../impl/ElasticsearchSimpleFlowStageTest.scala | 23 +-
.../impl/ElasticsearchSourcStageTest.scala | 8 +-
.../scaladsl/ElasticsearchConnectorBehaviour.scala | 228 ++++-----
.../scala/docs/scaladsl/ElasticsearchSpec.scala | 10 +-
.../docs/scaladsl/ElasticsearchSpecBase.scala | 10 +-
.../docs/scaladsl/ElasticsearchSpecUtils.scala | 23 +-
.../scala/docs/scaladsl/ElasticsearchV5Spec.scala | 179 +++----
.../scala/docs/scaladsl/ElasticsearchV7Spec.scala | 135 ++----
.../scaladsl/OpensearchConnectorBehaviour.scala | 228 ++++-----
.../scala/docs/scaladsl/OpensearchV1Spec.scala | 169 +++----
.../file/impl/archive/EnsureByteStreamSize.scala | 18 +-
.../file/impl/archive/TarArchiveEntry.scala | 27 +-
.../file/impl/archive/TarArchiveManager.scala | 2 +-
.../alpakka/file/impl/archive/TarReaderStage.scala | 29 +-
.../alpakka/file/impl/archive/ZipArchiveFlow.scala | 17 +-
.../file/impl/archive/ZipArchiveManager.scala | 2 +-
.../file/impl/archive/ZipReaderSource.scala | 16 +-
.../akka/stream/alpakka/file/javadsl/Archive.scala | 12 +-
.../alpakka/file/javadsl/LogRotatorSink.scala | 27 +-
.../scala/akka/stream/alpakka/file/model.scala | 63 ++-
.../stream/alpakka/file/scaladsl/Archive.scala | 14 +-
.../stream/alpakka/file/scaladsl/Directory.scala | 8 +-
.../file/scaladsl/DirectoryChangesSource.scala | 7 +-
.../alpakka/file/scaladsl/FileTailSource.scala | 19 +-
.../alpakka/file/scaladsl/LogRotatorSink.scala | 49 +-
.../file/impl/archive/TarArchiveEntrySpec.scala | 2 +-
.../file/impl/archive/ZipArchiveFlowTest.scala | 2 +-
.../src/test/scala/docs/scaladsl/ArchiveSpec.scala | 19 +-
.../test/scala/docs/scaladsl/DirectorySpec.scala | 10 +-
.../test/scala/docs/scaladsl/ExecutableUtils.scala | 8 +-
.../docs/scaladsl/FileTailSourceExtrasSpec.scala | 20 +-
.../scala/docs/scaladsl/FileTailSourceSpec.scala | 3 +-
.../scala/docs/scaladsl/LogRotatorSinkSpec.scala | 59 +--
.../test/scala/docs/scaladsl/TarArchiveSpec.scala | 43 +-
.../alpakka/ftp/impl/CommonFtpOperations.scala | 11 +-
.../alpakka/ftp/impl/FtpBrowserGraphStage.scala | 5 +-
.../impl/FtpDirectoryOperationsGraphStage.scala | 5 +-
.../stream/alpakka/ftp/impl/FtpGraphStage.scala | 2 +-
.../alpakka/ftp/impl/FtpGraphStageLogic.scala | 5 +-
.../stream/alpakka/ftp/impl/FtpIOGraphStage.scala | 41 +-
.../akka/stream/alpakka/ftp/impl/FtpLike.scala | 4 +-
.../stream/alpakka/ftp/impl/FtpOperations.scala | 13 +-
.../stream/alpakka/ftp/impl/FtpSourceFactory.scala | 58 +--
.../stream/alpakka/ftp/impl/FtpsOperations.scala | 10 +-
.../stream/alpakka/ftp/impl/SftpOperations.scala | 25 +-
.../akka/stream/alpakka/ftp/javadsl/FtpApi.scala | 164 +++----
.../main/scala/akka/stream/alpakka/ftp/model.scala | 91 ++--
.../akka/stream/alpakka/ftp/scaladsl/FtpApi.scala | 92 ++--
.../akka/stream/alpakka/ftp/BaseFtpSpec.scala | 16 +-
.../akka/stream/alpakka/ftp/BaseFtpsSpec.scala | 16 +-
.../akka/stream/alpakka/ftp/BaseSftpSpec.scala | 16 +-
.../scala/akka/stream/alpakka/ftp/BaseSpec.scala | 17 +-
.../stream/alpakka/ftp/CommonFtpStageSpec.scala | 56 +--
.../test/scala/docs/scaladsl/FtpExamplesSpec.scala | 16 +-
.../test/scala/docs/scaladsl/scalaExamples.scala | 44 +-
.../akka/stream/alpakka/geode/GeodeSettings.scala | 14 +-
.../stream/alpakka/geode/impl/GeodeCache.scala | 4 +-
.../alpakka/geode/impl/GeodeCapabilities.scala | 2 +-
.../geode/impl/pdx/DelegatingPdxSerializer.scala | 5 +-
.../stream/alpakka/geode/impl/pdx/PdxDecoder.scala | 12 +-
.../stream/alpakka/geode/impl/pdx/PdxEncoder.scala | 8 +-
.../geode/impl/pdx/ShapelessPdxSerializer.scala | 7 +-
.../geode/impl/stage/GeodeCQueryGraphLogic.scala | 14 +-
.../impl/stage/GeodeContinuousSourceStage.scala | 61 ++-
.../geode/impl/stage/GeodeFiniteSourceStage.scala | 31 +-
.../alpakka/geode/impl/stage/GeodeFlowStage.scala | 24 +-
.../geode/impl/stage/GeodeQueryGraphLogic.scala | 4 +-
.../geode/impl/stage/GeodeSourceStageLogic.scala | 4 +-
.../akka/stream/alpakka/geode/scaladsl/Geode.scala | 30 +-
.../alpakka/geode/impl/pdx/PDXDecoderSpec.scala | 2 +-
.../alpakka/geode/impl/pdx/PDXEncodeSpec.scala | 2 +-
.../alpakka/geode/impl/pdx/PdxWriterMock.scala | 8 +-
.../test/scala/docs/scaladsl/GeodeBaseSpec.scala | 8 +-
.../docs/scaladsl/GeodeContinuousSourceSpec.scala | 14 +-
.../docs/scaladsl/GeodeFiniteSourceSpec.scala | 4 +-
.../test/scala/docs/scaladsl/GeodeFlowSpec.scala | 14 +-
.../test/scala/docs/scaladsl/GeodeSinkSpec.scala | 8 +-
geode/src/test/scala/docs/scaladsl/Model.scala | 2 +-
.../scala/docs/scaladsl/PersonPdxSerializer.scala | 2 +-
.../bigquery/storage/BigQueryRecordMapImpl.scala | 4 +-
.../bigquery/storage/BigQueryStorageSettings.scala | 5 +-
.../bigquery/storage/ProtobufConverters.scala | 6 +-
.../bigquery/storage/impl/AkkaGrpcSettings.scala | 8 +-
.../bigquery/storage/impl/ArrowSource.scala | 21 +-
.../bigquery/storage/impl/AvroDecoder.scala | 2 +-
.../bigquery/storage/impl/AvroSource.scala | 18 +-
.../bigquery/storage/impl/SDKClientSource.scala | 2 +-
.../storage/javadsl/BigQueryArrowStorage.scala | 82 ++--
.../storage/javadsl/BigQueryAvroStorage.scala | 86 ++--
.../bigquery/storage/javadsl/BigQueryStorage.scala | 65 ++-
.../storage/scaladsl/BigQueryArrowStorage.scala | 88 ++--
.../storage/scaladsl/BigQueryAvroStorage.scala | 88 ++--
.../storage/scaladsl/BigQueryStorage.scala | 36 +-
.../scaladsl/BigQueryStorageAttributes.scala | 3 +-
.../scaladsl/GrpcBigQueryStorageReader.scala | 2 +-
.../storage/javadsl/AvroByteStringDecoder.scala | 6 +-
.../bigquery/storage/BigQueryStorageSpecBase.scala | 7 +-
.../bigquery/storage/mock/BigQueryMockData.scala | 10 +-
.../bigquery/storage/mock/BigQueryMockServer.scala | 23 +-
.../storage/scaladsl/ArrowByteStringDecoder.scala | 19 +-
.../storage/scaladsl/AvroByteStringDecoder.scala | 6 +-
.../scaladsl/BigQueryArrowStorageSpec.scala | 7 +-
.../storage/scaladsl/BigQueryStorageSpec.scala | 30 +-
.../test/scala/docs/scaladsl/ExampleReader.scala | 37 +-
.../googlecloud/bigquery/BigQueryAttributes.scala | 6 +-
.../googlecloud/bigquery/BigQueryException.scala | 9 +-
.../alpakka/googlecloud/bigquery/BigQueryExt.scala | 8 +-
.../googlecloud/bigquery/javadsl/BigQuery.scala | 118 +++--
.../javadsl/jackson/BigQueryMarshallers.scala | 11 +-
.../bigquery/model/DatasetJsonProtocol.scala | 14 +-
.../bigquery/model/ErrorProtoJsonProtocol.scala | 6 +-
.../bigquery/model/JobJsonProtocol.scala | 35 +-
.../bigquery/model/QueryJsonProtocol.scala | 117 +++--
.../googlecloud/bigquery/model/StringEnum.scala | 4 +-
.../bigquery/model/TableDataJsonProtocol.scala | 31 +-
.../bigquery/model/TableJsonProtocol.scala | 61 ++-
.../bigquery/scaladsl/BigQueryDatasets.scala | 22 +-
.../bigquery/scaladsl/BigQueryJobs.scala | 34 +-
.../bigquery/scaladsl/BigQueryQueries.scala | 41 +-
.../bigquery/scaladsl/BigQueryRest.scala | 4 +-
.../bigquery/scaladsl/BigQueryTableData.scala | 34 +-
.../bigquery/scaladsl/BigQueryTables.scala | 19 +-
.../bigquery/scaladsl/schema/BasicSchemas.scala | 2 +-
.../bigquery/scaladsl/schema/JavaTimeSchemas.scala | 4 +-
.../scaladsl/schema/PrimitiveSchemaWriter.scala | 2 +-
.../bigquery/scaladsl/schema/ProductSchemas.scala | 4 +-
.../bigquery/scaladsl/schema/SchemaWriter.scala | 2 +-
.../bigquery/scaladsl/schema/StandardSchemas.scala | 2 +-
.../scaladsl/spray/BigQueryBasicFormats.scala | 46 +-
.../scaladsl/spray/BigQueryCollectionFormats.scala | 8 +-
.../scaladsl/spray/BigQueryJavaTimeFormats.scala | 14 +-
.../scaladsl/spray/BigQueryJsonFormat.scala | 2 +-
.../scaladsl/spray/BigQueryJsonProtocol.scala | 2 +-
.../scaladsl/spray/BigQueryProductFormats.scala | 5 +-
.../scaladsl/spray/BigQueryRestBasicFormats.scala | 12 +-
.../scaladsl/spray/BigQueryRestJsonProtocol.scala | 2 +-
.../scaladsl/spray/BigQueryStandardFormats.scala | 2 +-
.../googlecloud/bigquery/HoverflySupport.scala | 7 +-
.../alpakka/googlecloud/bigquery/e2e/A.scala | 13 +-
.../e2e/scaladsl/BigQueryEndToEndSpec.scala | 13 +-
.../bigquery/e2e/scaladsl/EndToEndHelper.scala | 17 +-
.../bigquery/scaladsl/BigQueryQueriesSpec.scala | 43 +-
.../scaladsl/schema/BigQuerySchemasSpec.scala | 11 +-
.../scaladsl/spray/BigQueryJsonProtocolSpec.scala | 6 +-
.../src/test/scala/docs/scaladsl/BigQueryDoc.scala | 50 +-
.../googlecloud/pubsub/grpc/PubSubSettings.scala | 24 +-
.../pubsub/grpc/impl/AkkaGrpcSettings.scala | 8 +-
.../pubsub/grpc/impl/DeprecatedCredentials.scala | 4 +-
.../pubsub/grpc/javadsl/GooglePubSub.scala | 21 +-
.../pubsub/grpc/javadsl/GrpcPublisher.scala | 2 +-
.../pubsub/grpc/javadsl/GrpcSubscriber.scala | 6 +-
.../pubsub/grpc/scaladsl/GooglePubSub.scala | 28 +-
.../pubsub/grpc/scaladsl/GrpcPublisher.scala | 4 +-
.../pubsub/grpc/scaladsl/GrpcSubscriber.scala | 4 +-
.../src/test/scala/docs/scaladsl/ExampleApp.scala | 14 +-
.../test/scala/docs/scaladsl/IntegrationSpec.scala | 42 +-
.../googlecloud/pubsub/impl/PubSubApi.scala | 44 +-
.../googlecloud/pubsub/javadsl/GooglePubSub.scala | 28 +-
.../stream/alpakka/googlecloud/pubsub/model.scala | 116 +++--
.../googlecloud/pubsub/scaladsl/GooglePubSub.scala | 39 +-
.../googlecloud/pubsub/GooglePubSubSpec.scala | 27 +-
.../googlecloud/pubsub/impl/PubSubApiSpec.scala | 133 ++---
.../test/scala/docs/scaladsl/ExampleUsage.scala | 54 +--
.../test/scala/docs/scaladsl/IntegrationSpec.scala | 6 +-
.../alpakka/googlecloud/storage/Bucket.scala | 21 +-
.../googlecloud/storage/CustomerEncryption.scala | 2 +-
.../alpakka/googlecloud/storage/FailedUpload.scala | 3 +-
.../alpakka/googlecloud/storage/GCSExt.scala | 2 +-
.../alpakka/googlecloud/storage/GCStorageExt.scala | 2 +-
.../googlecloud/storage/GCStorageSettings.scala | 26 +-
.../googlecloud/storage/ObjectAccessControls.scala | 147 +++---
.../googlecloud/storage/StorageObject.scala | 24 +-
.../googlecloud/storage/StorageSettings.scala | 4 +-
.../storage/impl/BucketListResult.scala | 12 +-
.../alpakka/googlecloud/storage/impl/Formats.scala | 102 ++--
.../googlecloud/storage/impl/GCStorageStream.scala | 81 ++--
.../googlecloud/storage/impl/RewriteResponse.scala | 3 +-
.../storage/impl/UploadPartResponse.scala | 4 +-
.../googlecloud/storage/javadsl/GCStorage.scala | 77 ++-
.../googlecloud/storage/scaladsl/GCStorage.scala | 57 ++-
.../alpakka/googlecloud/storage/settings.scala | 2 +-
.../alpakka/googlecloud/storage/GCSExtSpec.scala | 4 +-
.../googlecloud/storage/GCSSettingsSpec.scala | 4 +-
.../googlecloud/storage/GCStorageExtSpec.scala | 4 +-
.../storage/GCStorageSettingsSpec.scala | 4 +-
.../storage/WithMaterializerGlobal.scala | 4 +-
.../impl/GCStorageStreamIntegrationSpec.scala | 49 +-
.../storage/scaladsl/GCStorageWiremockBase.scala | 212 +++-----
.../scala/docs/scaladsl/GCStorageSinkSpec.scala | 21 +-
.../scala/docs/scaladsl/GCStorageSourceSpec.scala | 127 ++---
.../stream/alpakka/google/GoogleAttributes.scala | 4 +-
.../akka/stream/alpakka/google/GoogleExt.scala | 8 +-
.../stream/alpakka/google/GoogleSettings.scala | 66 ++-
.../stream/alpakka/google/PaginatedRequest.scala | 5 +-
.../stream/alpakka/google/ResumableUpload.scala | 34 +-
.../stream/alpakka/google/auth/AccessToken.scala | 2 +-
.../google/auth/ComputeEngineCredentials.scala | 4 +-
.../stream/alpakka/google/auth/Credentials.scala | 18 +-
.../google/auth/GoogleComputeMetadata.scala | 6 +-
.../stream/alpakka/google/auth/GoogleOAuth2.scala | 19 +-
.../google/auth/GoogleOAuth2Credentials.scala | 11 +-
.../google/auth/GoogleOAuth2Exception.scala | 11 +-
.../stream/alpakka/google/auth/NoCredentials.scala | 4 +-
.../alpakka/google/auth/OAuth2Credentials.scala | 20 +-
.../google/auth/ServiceAccountCredentials.scala | 24 +-
.../google/auth/UserAccessCredentials.scala | 36 +-
.../alpakka/google/auth/UserAccessMetadata.scala | 8 +-
.../google/http/ForwardProxyHttpsContext.scala | 6 +-
.../google/http/ForwardProxyPoolSettings.scala | 26 +-
.../stream/alpakka/google/http/GoogleHttp.scala | 119 +++--
.../akka/stream/alpakka/google/implicits.scala | 7 +-
.../stream/alpakka/google/javadsl/Google.scala | 19 +-
.../stream/alpakka/google/scaladsl/Google.scala | 7 +-
.../google/scaladsl/`X-Upload-Content-Type`.scala | 11 +-
.../stream/alpakka/google/util/AnnotateLast.scala | 2 +-
.../stream/alpakka/google/util/EitherFlow.scala | 14 +-
.../akka/stream/alpakka/google/util/Retry.scala | 18 +-
.../alpakka/google/GoogleHttpException.scala | 2 +-
.../stream/alpakka/google/GoogleSettingsSpec.scala | 6 +-
.../stream/alpakka/google/HoverflySupport.scala | 7 +-
.../alpakka/google/PaginatedRequestSpec.scala | 22 +-
.../alpakka/google/ResumableUploadSpec.scala | 16 +-
.../alpakka/google/auth/GoogleOAuth2Spec.scala | 8 +-
.../google/auth/OAuth2CredentialsSpec.scala | 8 +-
.../alpakka/google/http/GoogleHttpSpec.scala | 62 +--
.../test/scala/docs/scaladsl/GoogleCommonDoc.scala | 10 +-
.../firebase/fcm/FcmNotificationModels.scala | 15 +-
.../alpakka/google/firebase/fcm/FcmSettings.scala | 79 ++-
.../google/firebase/fcm/impl/FcmFlows.scala | 12 +-
.../google/firebase/fcm/impl/FcmJsonSupport.scala | 21 +-
.../google/firebase/fcm/impl/FcmSender.scala | 9 +-
.../google/firebase/fcm/javadsl/GoogleFcm.scala | 6 +-
.../google/firebase/fcm/scaladsl/GoogleFcm.scala | 6 +-
.../google/firebase/fcm/v1/impl/FcmFlows.scala | 2 +-
.../firebase/fcm/v1/impl/FcmJsonSupport.scala | 61 ++-
.../google/firebase/fcm/v1/impl/FcmSender.scala | 9 +-
.../google/firebase/fcm/v1/javadsl/GoogleFcm.scala | 4 +-
.../firebase/fcm/v1/models/AndroidConfig.scala | 9 +-
.../google/firebase/fcm/v1/models/ApnsConfig.scala | 3 +-
.../firebase/fcm/v1/models/FcmNotification.scala | 7 +-
.../firebase/fcm/v1/models/WebPushConfig.scala | 6 +-
.../firebase/fcm/v1/scaladsl/GoogleFcm.scala | 6 +-
.../firebase/fcm/v1/FcmNotificationSpec.scala | 2 +-
.../firebase/fcm/v1/impl/FcmSenderSpec.scala | 48 +-
.../src/test/scala/docs/scaladsl/FcmExamples.scala | 32 +-
.../akka/stream/alpakka/hbase/HTableSettings.scala | 24 +-
.../alpakka/hbase/impl/HBaseCapabilities.scala | 11 +-
.../stream/alpakka/hbase/impl/HBaseFlowStage.scala | 22 +-
.../alpakka/hbase/impl/HBaseSourceStage.scala | 12 +-
.../stream/alpakka/hbase/javadsl/HTableStage.scala | 8 +-
.../alpakka/hbase/scaladsl/HTableStage.scala | 8 +-
.../test/scala/docs/scaladsl/HBaseStageSpec.scala | 40 +-
.../stream/alpakka/hdfs/impl/HdfsFlowStage.scala | 20 +-
.../impl/strategy/DefaultRotationStrategy.scala | 6 +-
.../hdfs/impl/strategy/DefaultSyncStrategy.scala | 3 +-
.../hdfs/impl/writer/CompressedDataWriter.scala | 10 +-
.../alpakka/hdfs/impl/writer/DataWriter.scala | 5 +-
.../alpakka/hdfs/impl/writer/HdfsWriter.scala | 2 +-
.../alpakka/hdfs/impl/writer/SequenceWriter.scala | 33 +-
.../stream/alpakka/hdfs/javadsl/HdfsFlow.scala | 43 +-
.../stream/alpakka/hdfs/javadsl/HdfsSource.scala | 21 +-
.../scala/akka/stream/alpakka/hdfs/model.scala | 12 +-
.../stream/alpakka/hdfs/scaladsl/HdfsFlow.scala | 60 +--
.../stream/alpakka/hdfs/scaladsl/HdfsSource.scala | 17 +-
.../akka/stream/alpakka/hdfs/util/TestUtils.scala | 33 +-
.../test/scala/docs/scaladsl/HdfsReaderSpec.scala | 40 +-
.../test/scala/docs/scaladsl/HdfsWriterSpec.scala | 116 ++---
.../huawei/pushkit/ForwardProxyHttpsContext.scala | 8 +-
.../huawei/pushkit/ForwardProxyPoolSettings.scala | 10 +-
.../alpakka/huawei/pushkit/HmsSettingExt.scala | 8 +-
.../alpakka/huawei/pushkit/HmsSettings.scala | 49 +-
.../alpakka/huawei/pushkit/impl/HmsTokenApi.scala | 17 +-
.../alpakka/huawei/pushkit/impl/PushKitFlows.scala | 12 +-
.../huawei/pushkit/impl/PushKitJsonSupport.scala | 33 +-
.../huawei/pushkit/impl/PushKitSender.scala | 19 +-
.../huawei/pushkit/javadsl/HmsPushKit.scala | 4 +-
.../huawei/pushkit/models/AndroidConfig.scala | 104 ++--
.../alpakka/huawei/pushkit/models/ApnsConfig.scala | 4 +-
.../pushkit/models/PushKitNotification.scala | 18 +-
.../alpakka/huawei/pushkit/models/WebConfig.scala | 30 +-
.../huawei/pushkit/scaladsl/HmsPushKit.scala | 6 +-
.../huawei/pushkit/ConditionBuilderSpec.scala | 2 +-
.../huawei/pushkit/impl/HmsTokenApiSpec.scala | 41 +-
.../huawei/pushkit/impl/PushKitSenderSpec.scala | 54 +--
.../test/scala/docs/scaladsl/PushKitExamples.scala | 22 +-
.../alpakka/influxdb/InfluxDbReadSettings.scala | 6 +-
.../alpakka/influxdb/InfluxDbWriteMessage.scala | 18 +-
.../influxdb/impl/AlpakkaResultMapperHelper.scala | 36 +-
.../alpakka/influxdb/impl/InfluxDbFlowStage.scala | 44 +-
.../influxdb/impl/InfluxDbSourceStage.scala | 38 +-
.../alpakka/influxdb/javadsl/InfluxDbFlow.scala | 20 +-
.../alpakka/influxdb/javadsl/InfluxDbSink.scala | 16 +-
.../alpakka/influxdb/javadsl/InfluxDbSource.scala | 8 +-
.../alpakka/influxdb/scaladsl/InfluxDbFlow.scala | 20 +-
.../alpakka/influxdb/scaladsl/InfluxDbSink.scala | 8 +-
.../alpakka/influxdb/scaladsl/InfluxDbSource.scala | 8 +-
.../src/test/scala/docs/scaladsl/FlowSpec.scala | 35 +-
.../scala/docs/scaladsl/InfluxDbSourceSpec.scala | 10 +-
.../test/scala/docs/scaladsl/InfluxDbSpec.scala | 32 +-
.../stream/alpakka/ironmq/IronMqSettings.scala | 41 +-
.../scala/akka/stream/alpakka/ironmq/domain.scala | 2 +-
.../akka/stream/alpakka/ironmq/impl/Codec.scala | 2 +-
.../stream/alpakka/ironmq/impl/IronMqClient.scala | 62 ++-
.../alpakka/ironmq/impl/IronMqPullStage.scala | 10 +-
.../alpakka/ironmq/impl/IronMqPushStage.scala | 16 +-
.../alpakka/ironmq/javadsl/IronMqConsumer.scala | 2 +-
.../alpakka/ironmq/javadsl/IronMqProducer.scala | 26 +-
.../alpakka/ironmq/scaladsl/IronMqProducer.scala | 15 +-
.../akka/stream/alpakka/ironmq/IronMqSpec.scala | 4 +-
.../alpakka/ironmq/impl/IronMqClientForTests.scala | 2 +-
.../alpakka/ironmq/impl/IronMqClientSpec.scala | 2 +-
.../alpakka/ironmq/impl/IronMqPullStageSpec.scala | 4 +-
.../alpakka/ironmq/impl/IronMqPushStageSpec.scala | 2 +-
.../ironmq/scaladsl/IronMqConsumerSpec.scala | 6 +-
.../ironmq/scaladsl/IronMqProducerSpec.scala | 14 +-
.../test/scala/docs/scaladsl/IronMqDocsSpec.scala | 10 +-
.../akka/stream/alpakka/jms/AcknowledgeMode.scala | 15 +-
.../alpakka/jms/ConnectionRetrySettings.scala | 14 +-
.../akka/stream/alpakka/jms/Credentials.scala | 24 +-
.../akka/stream/alpakka/jms/Destinations.scala | 2 +-
.../scala/akka/stream/alpakka/jms/Envelopes.scala | 4 +-
.../stream/alpakka/jms/JmsBrowseSettings.scala | 20 +-
.../stream/alpakka/jms/JmsConsumerSettings.scala | 21 +-
.../akka/stream/alpakka/jms/JmsExceptions.scala | 15 +-
.../akka/stream/alpakka/jms/JmsMessages.scala | 279 +++++------
.../stream/alpakka/jms/JmsProducerSettings.scala | 23 +-
.../stream/alpakka/jms/SendRetrySettings.scala | 17 +-
.../alpakka/jms/impl/InternalConnectionState.scala | 6 +-
.../alpakka/jms/impl/JmsAckSourceStage.scala | 12 +-
.../stream/alpakka/jms/impl/JmsBrowseStage.scala | 6 +-
.../stream/alpakka/jms/impl/JmsConnector.scala | 56 +--
.../stream/alpakka/jms/impl/JmsConsumerStage.scala | 5 +-
.../alpakka/jms/impl/JmsMessageProducer.scala | 48 +-
.../stream/alpakka/jms/impl/JmsMessageReader.scala | 12 +-
.../stream/alpakka/jms/impl/JmsProducerStage.scala | 37 +-
.../stream/alpakka/jms/impl/JmsTxSourceStage.scala | 16 +-
.../akka/stream/alpakka/jms/impl/Sessions.scala | 27 +-
.../stream/alpakka/jms/impl/SourceStageLogic.scala | 23 +-
.../stream/alpakka/jms/javadsl/JmsConsumer.scala | 6 +-
.../stream/alpakka/jms/javadsl/JmsProducer.scala | 22 +-
.../alpakka/jms/scaladsl/JmsConnectorState.scala | 12 +-
.../stream/alpakka/jms/scaladsl/JmsConsumer.scala | 2 +-
.../stream/alpakka/jms/scaladsl/JmsProducer.scala | 22 +-
.../akka/stream/alpakka/jms/scaladsl/package.scala | 18 +-
.../alpakka/jms/JmsConnectionStatusSpec.scala | 36 +-
.../stream/alpakka/jms/JmsProducerRetrySpec.scala | 40 +-
.../scala/akka/stream/alpakka/jms/JmsSpec.scala | 22 +-
.../alpakka/jms/impl/JmsMessageProducerSpec.scala | 20 +-
.../alpakka/jms/impl/SoftReferenceCacheSpec.scala | 4 +-
.../jms/scaladsl/CachedConnectionFactory.scala | 2 +-
.../jms/scaladsl/JmsAckConnectorsSpec.scala | 101 ++--
.../scaladsl/JmsBufferedAckConnectorsSpec.scala | 96 ++--
.../scala/docs/scaladsl/JmsConnectorsSpec.scala | 359 ++++++--------
.../docs/scaladsl/JmsIbmmqConnectorsSpec.scala | 60 ++-
.../test/scala/docs/scaladsl/JmsSettingsSpec.scala | 22 +-
.../scala/docs/scaladsl/JmsTxConnectorsSpec.scala | 147 +++---
.../alpakka/json/impl/JsonStreamReader.scala | 13 +-
.../test/scala/docs/scaladsl/JsonReaderTest.scala | 2 +-
.../stream/alpakka/kinesis/CommittableRecord.scala | 11 +-
.../stream/alpakka/kinesis/KinesisErrors.scala | 2 +-
.../alpakka/kinesis/KinesisFlowSettings.scala | 18 +-
.../alpakka/kinesis/KinesisSchedulerSettings.scala | 6 +-
.../stream/alpakka/kinesis/ShardSettings.scala | 21 +-
.../kinesis/impl/KinesisSchedulerSourceStage.scala | 16 +-
.../alpakka/kinesis/impl/KinesisSourceStage.scala | 20 +-
.../alpakka/kinesis/impl/ShardProcessor.scala | 21 +-
.../alpakka/kinesis/javadsl/KinesisFlow.scala | 18 +-
.../kinesis/javadsl/KinesisSchedulerSource.scala | 19 +-
.../alpakka/kinesis/javadsl/KinesisSink.scala | 6 +-
.../alpakka/kinesis/javadsl/KinesisSource.scala | 4 +-
.../alpakka/kinesis/scaladsl/KinesisFlow.scala | 66 +--
.../kinesis/scaladsl/KinesisSchedulerSource.scala | 18 +-
.../alpakka/kinesis/scaladsl/KinesisSink.scala | 15 +-
.../alpakka/kinesis/scaladsl/KinesisSource.scala | 8 +-
.../KinesisFirehoseFlowSettings.scala | 18 +-
.../javadsl/KinesisFirehoseFlow.scala | 10 +-
.../javadsl/KinesisFirehoseSink.scala | 8 +-
.../scaladsl/KinesisFirehoseFlow.scala | 28 +-
.../scaladsl/KinesisFirehoseSink.scala | 3 +-
.../alpakka/kinesis/DefaultTestContext.scala | 9 +-
.../stream/alpakka/kinesis/KinesisFlowSpec.scala | 22 +-
.../akka/stream/alpakka/kinesis/KinesisMock.scala | 2 +-
.../kinesis/KinesisSchedulerSourceSpec.scala | 76 ++-
.../stream/alpakka/kinesis/KinesisSourceSpec.scala | 15 +-
.../scala/akka/stream/alpakka/kinesis/Valve.scala | 13 +-
.../kinesisfirehose/KinesisFirehoseFlowSpec.scala | 2 +-
.../kinesisfirehose/KinesisFirehoseMock.scala | 2 +-
.../src/test/scala/docs/scaladsl/KclSnippets.scala | 34 +-
.../docs/scaladsl/KinesisFirehoseSnippets.scala | 22 +-
.../test/scala/docs/scaladsl/KinesisSnippets.scala | 39 +-
.../akka/stream/alpakka/kudu/KuduClientExt.scala | 2 +-
.../stream/alpakka/kudu/KuduTableSettings.scala | 33 +-
.../alpakka/kudu/impl/KuduCapabilities.scala | 6 +-
.../stream/alpakka/kudu/impl/KuduFlowStage.scala | 16 +-
.../stream/alpakka/kudu/javadsl/KuduTable.scala | 4 +-
.../stream/alpakka/kudu/scaladsl/KuduTable.scala | 8 +-
.../test/scala/docs/scaladsl/KuduTableSpec.scala | 24 +-
.../stream/alpakka/mongodb/DocumentReplace.scala | 1 -
.../stream/alpakka/mongodb/DocumentUpdate.scala | 1 -
.../stream/alpakka/mongodb/javadsl/MongoFlow.scala | 29 +-
.../stream/alpakka/mongodb/javadsl/MongoSink.scala | 17 +-
.../alpakka/mongodb/scaladsl/MongoFlow.scala | 56 +--
.../alpakka/mongodb/scaladsl/MongoSink.scala | 22 +-
.../test/scala/docs/scaladsl/MongoSinkSpec.scala | 43 +-
.../test/scala/docs/scaladsl/MongoSourceSpec.scala | 6 +-
.../scala/akka/stream/alpakka/mqtt/MqttPerf.scala | 17 +-
.../stream/alpakka/mqtt/streaming/MqttPerf.scala | 18 +-
.../mqtt/streaming/MqttSessionSettings.scala | 64 ++-
.../mqtt/streaming/impl/BehaviorRunner.scala | 4 +-
.../alpakka/mqtt/streaming/impl/ClientState.scala | 228 ++++-----
.../mqtt/streaming/impl/MqttFrameStage.scala | 19 +-
.../mqtt/streaming/impl/QueueOfferState.scala | 8 +-
.../alpakka/mqtt/streaming/impl/RequestState.scala | 138 +++---
.../alpakka/mqtt/streaming/impl/ServerState.scala | 360 ++++++--------
.../alpakka/mqtt/streaming/javadsl/Mqtt.scala | 11 +-
.../akka/stream/alpakka/mqtt/streaming/model.scala | 175 ++++---
.../alpakka/mqtt/streaming/scaladsl/Mqtt.scala | 20 +-
.../mqtt/streaming/scaladsl/MqttSession.scala | 178 ++++---
.../mqtt/streaming/impl/MqttFrameStageSpec.scala | 2 +-
.../mqtt/streaming/impl/QueueOfferStateSpec.scala | 13 +-
.../mqtt/streaming/impl/RequestStateSpec.scala | 12 +-
.../scala/docs/scaladsl/MqttActorSystemsSpec.scala | 2 +-
.../test/scala/docs/scaladsl/MqttCodecSpec.scala | 43 +-
.../test/scala/docs/scaladsl/MqttFlowSpec.scala | 58 ++-
.../test/scala/docs/scaladsl/MqttSessionSpec.scala | 150 +++---
.../stream/alpakka/mqtt/impl/MqttFlowStage.scala | 88 ++--
.../alpakka/mqtt/impl/MqttFlowStageWithAck.scala | 58 +--
.../stream/alpakka/mqtt/javadsl/MqttFlow.scala | 12 +-
.../stream/alpakka/mqtt/javadsl/MqttSink.scala | 4 +-
.../stream/alpakka/mqtt/javadsl/MqttSource.scala | 8 +-
.../scala/akka/stream/alpakka/mqtt/model.scala | 24 +-
.../stream/alpakka/mqtt/scaladsl/MqttFlow.scala | 40 +-
.../stream/alpakka/mqtt/scaladsl/MqttSink.scala | 2 +-
.../stream/alpakka/mqtt/scaladsl/MqttSource.scala | 16 +-
.../scala/akka/stream/alpakka/mqtt/settings.scala | 84 ++--
.../test/scala/docs/scaladsl/MqttFlowSpec.scala | 28 +-
.../test/scala/docs/scaladsl/MqttSinkSpec.scala | 22 +-
.../test/scala/docs/scaladsl/MqttSourceSpec.scala | 118 ++---
.../test/scala/docs/scaladsl/MqttSpecBase.scala | 5 +-
.../alpakka/orientdb/OrientDbSourceSettings.scala | 15 +-
.../alpakka/orientdb/OrientDbWriteSettings.scala | 17 +-
.../alpakka/orientdb/impl/OrientDbFlowStage.scala | 9 +-
.../orientdb/impl/OrientDbSourceStage.scala | 19 +-
.../alpakka/orientdb/javadsl/OrientDbFlow.scala | 20 +-
.../alpakka/orientdb/javadsl/OrientDbSink.scala | 14 +-
.../alpakka/orientdb/javadsl/OrientDbSource.scala | 22 +-
.../alpakka/orientdb/scaladsl/OrientDbFlow.scala | 36 +-
.../alpakka/orientdb/scaladsl/OrientDbSink.scala | 10 +-
.../alpakka/orientdb/scaladsl/OrientDbSource.scala | 18 +-
.../test/scala/docs/scaladsl/OrientDbSpec.scala | 87 ++--
.../akka/stream/alpakka/pravega/PravegaEvent.scala | 2 +-
.../pravega/PravegaReaderGroupManager.scala | 12 +-
.../stream/alpakka/pravega/PravegaSettings.scala | 327 ++++++-------
.../alpakka/pravega/impl/PravegaCapabilities.scala | 2 +-
.../stream/alpakka/pravega/impl/PravegaFlow.scala | 27 +-
.../alpakka/pravega/impl/PravegaSource.scala | 30 +-
.../pravega/impl/PravegaTableReadFlow.scala | 20 +-
.../alpakka/pravega/impl/PravegaTableSource.scala | 26 +-
.../pravega/impl/PravegaTableWriteFlow.scala | 31 +-
.../alpakka/pravega/impl/PravegaWriter.scala | 3 +-
.../stream/alpakka/pravega/scaladsl/Pravega.scala | 8 +-
.../alpakka/pravega/scaladsl/PravegaTable.scala | 31 +-
.../stream/alpakka/pravega/PravegaBaseSpec.scala | 2 +-
.../stream/alpakka/pravega/PravegaGraphSpec.scala | 13 +-
.../alpakka/pravega/PravegaKVTableSpec.scala | 2 +-
.../pravega/PravegaStreamAndTableSpec.scala | 16 +-
.../scala/docs/scaladsl/PravegaReadWriteDocs.scala | 4 +-
.../scala/docs/scaladsl/PravegaSettingsSpec.scala | 23 +-
project/AutomaticModuleName.scala | 5 +-
project/Common.scala | 169 ++++---
project/Dependencies.scala | 534 +++++++++-----------
project/TestChanged.scala | 15 +-
.../reference/impl/ReferenceFlowStage.scala | 19 +-
.../reference/impl/ReferenceSourceStage.scala | 21 +-
.../impl/ReferenceWithResourceFlowStage.scala | 19 +-
.../alpakka/reference/javadsl/Reference.scala | 13 +-
.../akka/stream/alpakka/reference/model.scala | 14 +-
.../alpakka/reference/scaladsl/Reference.scala | 8 +-
.../akka/stream/alpakka/reference/settings.scala | 14 +-
.../alpakka/reference/testkit/MessageFactory.scala | 8 +-
.../test/scala/docs/scaladsl/ReferenceSpec.scala | 17 +-
.../scala/akka/stream/alpakka/s3/S3Exception.scala | 13 +-
.../main/scala/akka/stream/alpakka/s3/S3Ext.scala | 2 +-
.../scala/akka/stream/alpakka/s3/S3Headers.scala | 19 +-
.../main/scala/akka/stream/alpakka/s3/Utils.scala | 3 +-
.../alpakka/s3/headers/ServerSideEncryption.scala | 34 +-
.../scala/akka/stream/alpakka/s3/impl/Chunk.scala | 2 +-
.../akka/stream/alpakka/s3/impl/DiskBuffer.scala | 2 +-
.../akka/stream/alpakka/s3/impl/HttpRequests.scala | 122 ++---
.../akka/stream/alpakka/s3/impl/Marshalling.scala | 81 ++--
.../akka/stream/alpakka/s3/impl/MemoryBuffer.scala | 4 +-
.../stream/alpakka/s3/impl/MemoryWithContext.scala | 4 +-
.../akka/stream/alpakka/s3/impl/S3Stream.scala | 538 +++++++++------------
.../stream/alpakka/s3/impl/SplitAfterSize.scala | 2 +-
.../s3/impl/SplitAfterSizeWithContext.scala | 10 +-
.../alpakka/s3/impl/auth/CanonicalRequest.scala | 19 +-
.../akka/stream/alpakka/s3/impl/auth/Signer.scala | 26 +-
.../stream/alpakka/s3/impl/auth/SigningKey.scala | 10 +-
.../scala/akka/stream/alpakka/s3/javadsl/S3.scala | 434 ++++++++---------
.../main/scala/akka/stream/alpakka/s3/model.scala | 270 +++++------
.../scala/akka/stream/alpakka/s3/scaladsl/S3.scala | 219 ++++-----
.../scala/akka/stream/alpakka/s3/settings.scala | 100 ++--
.../akka/stream/alpakka/s3/MinioContainer.scala | 4 +-
.../scala/akka/stream/alpakka/s3/MinioS3Test.scala | 5 +-
.../akka/stream/alpakka/s3/S3SettingsSpec.scala | 37 +-
.../stream/alpakka/s3/impl/DiskBufferSpec.scala | 18 +-
.../stream/alpakka/s3/impl/HttpRequestsSpec.scala | 57 +--
.../stream/alpakka/s3/impl/MarshallingSpec.scala | 93 ++--
.../stream/alpakka/s3/impl/MemoryBufferSpec.scala | 9 +-
.../stream/alpakka/s3/impl/S3HeadersSpec.scala | 15 +-
.../akka/stream/alpakka/s3/impl/S3StreamSpec.scala | 56 +--
.../alpakka/s3/impl/SplitAfterSizeSpec.scala | 40 +-
.../s3/impl/auth/CanonicalRequestSpec.scala | 58 +--
.../stream/alpakka/s3/impl/auth/SignerSpec.scala | 34 +-
.../alpakka/s3/impl/auth/SigningKeySpec.scala | 10 +-
.../impl/auth/SplitAfterSizeWithContextSpec.scala | 19 +-
.../alpakka/s3/impl/auth/StreamUtilsSpec.scala | 10 +-
.../s3/scaladsl/S3ClientIntegrationSpec.scala | 2 +-
.../stream/alpakka/s3/scaladsl/S3ExtSpec.scala | 4 +-
.../alpakka/s3/scaladsl/S3IntegrationSpec.scala | 246 ++++------
.../s3/scaladsl/S3SlowMinioIntegrationSpec.scala | 9 +-
.../alpakka/s3/scaladsl/S3WireMockBase.scala | 222 +++------
s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala | 120 ++---
s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala | 58 ++-
.../recordio/impl/RecordIOFramingStage.scala | 10 +-
.../scala/docs/scaladsl/RecordIOFramingSpec.scala | 71 ++-
.../akka/stream/alpakka/slick/javadsl/Slick.scala | 67 ++-
.../stream/alpakka/slick/javadsl/package.scala | 3 +-
.../akka/stream/alpakka/slick/scaladsl/Slick.scala | 22 +-
.../stream/alpakka/slick/scaladsl/package.scala | 2 +-
.../src/test/scala/docs/scaladsl/DocSnippets.scala | 31 +-
slick/src/test/scala/docs/scaladsl/SlickSpec.scala | 56 +--
.../stream/alpakka/sns/javadsl/SnsPublisher.scala | 26 +-
.../stream/alpakka/sns/scaladsl/SnsPublisher.scala | 25 +-
.../stream/alpakka/sns/DefaultTestContext.scala | 2 +-
.../alpakka/sns/IntegrationTestContext.scala | 14 +-
.../stream/alpakka/sns/SnsPublishMockingSpec.scala | 6 +-
.../scala/docs/scaladsl/SnsPublisherSpec.scala | 26 +-
.../akka/stream/alpakka/solr/SolrMessages.scala | 42 +-
.../stream/alpakka/solr/SolrUpdateSettings.scala | 9 +-
.../stream/alpakka/solr/impl/SolrFlowStage.scala | 44 +-
.../stream/alpakka/solr/impl/SolrSourceStage.scala | 4 +-
.../stream/alpakka/solr/javadsl/SolrFlow.scala | 61 +--
.../stream/alpakka/solr/javadsl/SolrSink.scala | 21 +-
.../stream/alpakka/solr/scaladsl/SolrFlow.scala | 65 +--
.../stream/alpakka/solr/scaladsl/SolrSink.scala | 16 +-
solr/src/test/scala/docs/scaladsl/SolrSpec.scala | 165 +++----
.../stream/alpakka/sqs/SqsAckBatchSettings.scala | 3 +-
.../stream/alpakka/sqs/SqsAckGroupedSettings.scala | 33 +-
.../akka/stream/alpakka/sqs/SqsAckSettings.scala | 12 +-
.../scala/akka/stream/alpakka/sqs/SqsModel.scala | 39 +-
.../alpakka/sqs/SqsPublishBatchSettings.scala | 3 +-
.../alpakka/sqs/SqsPublishGroupedSettings.scala | 21 +-
.../stream/alpakka/sqs/SqsSourceSettings.scala | 22 +-
.../alpakka/sqs/impl/BalancingMapAsync.scala | 41 +-
.../stream/alpakka/sqs/javadsl/SqsAckFlow.scala | 8 +-
.../stream/alpakka/sqs/javadsl/SqsAckSink.scala | 10 +-
.../alpakka/sqs/javadsl/SqsPublishFlow.scala | 14 +-
.../alpakka/sqs/javadsl/SqsPublishSink.scala | 27 +-
.../stream/alpakka/sqs/scaladsl/SqsAckFlow.scala | 41 +-
.../stream/alpakka/sqs/scaladsl/SqsAckSink.scala | 10 +-
.../alpakka/sqs/scaladsl/SqsPublishFlow.scala | 39 +-
.../alpakka/sqs/scaladsl/SqsPublishSink.scala | 36 +-
.../stream/alpakka/sqs/scaladsl/SqsSource.scala | 11 +-
.../alpakka/sqs/testkit/MessageFactory.scala | 17 +-
.../alpakka/sqs/scaladsl/DefaultTestContext.scala | 20 +-
.../sqs/scaladsl/MessageAttributeNameSpec.scala | 3 +-
.../alpakka/sqs/scaladsl/SqsPublishSinkSpec.scala | 62 +--
.../alpakka/sqs/scaladsl/SqsSourceMockSpec.scala | 27 +-
sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala | 69 ++-
.../test/scala/docs/scaladsl/SqsPublishSpec.scala | 57 ++-
.../test/scala/docs/scaladsl/SqsSourceSpec.scala | 30 +-
.../stream/alpakka/sse/javadsl/EventSource.scala | 28 +-
.../stream/alpakka/sse/scaladsl/EventSource.scala | 23 +-
.../test/scala/docs/scaladsl/EventSourceSpec.scala | 28 +-
.../stream/alpakka/testkit/CapturingAppender.scala | 7 +-
.../akka/stream/alpakka/testkit/LogbackUtil.scala | 9 +-
.../testkit/javadsl/LogCapturingJunit4.scala | 9 +-
.../alpakka/testkit/scaladsl/LogCapturing.scala | 6 +-
.../stream/alpakka/testkit/scaladsl/Repeated.scala | 2 +-
.../alpakka/text/impl/CharsetDecodingFlow.scala | 4 +-
.../stream/alpakka/text/impl/CharsetLogic.scala | 28 +-
.../alpakka/text/impl/CharsetTranscodingFlow.scala | 4 +-
.../stream/alpakka/text/javadsl/TextFlow.scala | 2 +-
.../stream/alpakka/text/scaladsl/TextFlow.scala | 2 +-
.../text/scaladsl/CharsetCodingFlowsSpec.scala | 10 +-
.../docs/scaladsl/CharsetCodingFlowsDoc.scala | 4 +-
.../akka/stream/alpakka/udp/impl/UdpBind.scala | 27 +-
.../akka/stream/alpakka/udp/impl/UdpSend.scala | 20 +-
.../akka/stream/alpakka/udp/javadsl/Udp.scala | 20 +-
.../akka/stream/alpakka/udp/scaladsl/Udp.scala | 24 +-
udp/src/test/scala/docs/scaladsl/UdpSpec.scala | 4 +-
.../impl/UnixDomainSocketImpl.scala | 102 ++--
.../javadsl/UnixDomainSocket.scala | 22 +-
.../scaladsl/UnixDomainSocket.scala | 21 +-
.../scala/docs/scaladsl/UnixDomainSocketSpec.scala | 27 +-
.../akka/stream/alpakka/xml/impl/Coalesce.scala | 10 +-
.../alpakka/xml/impl/StreamingXmlParser.scala | 27 +-
.../alpakka/xml/impl/StreamingXmlWriter.scala | 6 +-
.../akka/stream/alpakka/xml/impl/Subslice.scala | 6 +-
.../akka/stream/alpakka/xml/impl/Subtree.scala | 6 +-
.../stream/alpakka/xml/javadsl/XmlParsing.scala | 6 +-
.../stream/alpakka/xml/javadsl/XmlWriting.scala | 4 +-
.../main/scala/akka/stream/alpakka/xml/model.scala | 46 +-
.../stream/alpakka/xml/scaladsl/XmlParsing.scala | 2 +-
.../stream/alpakka/xml/scaladsl/XmlWriting.scala | 2 +-
.../test/scala/docs/scaladsl/XmlCoalesceSpec.scala | 14 +-
.../scala/docs/scaladsl/XmlProcessingSpec.scala | 92 ++--
.../test/scala/docs/scaladsl/XmlSubsliceSpec.scala | 22 +-
.../test/scala/docs/scaladsl/XmlSubtreeSpec.scala | 22 +-
.../test/scala/docs/scaladsl/XmlWritingSpec.scala | 47 +-
758 files changed, 10276 insertions(+), 13309 deletions(-)
create mode 100644 .gitattributes
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
