Path	Lines of Code
amqp/src/test/java/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpConnectionProvidersTest.java	247
amqp/src/test/java/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpConnectorsTest.java	211
amqp/src/test/java/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlowTest.java	129
amqp/src/test/resources/logback-test.xml	23
amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/AmqpProxyConnection.scala	41
amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/AmqpSpec.scala	16
amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpConnectionProvidersSpec.scala	176
amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpConnectorsSpec.scala	354
amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlowSpec.scala	344
amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpGraphStageLogicConnectionShutdownSpec.scala	75
amqp/src/test/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpMocking.scala	19
avroparquet/src/test/resources/logback-test.xml	23
aws-event-bridge/src/test/resources/logback-test.xml	23
aws-event-bridge/src/test/scala/org/apache/pekko/stream/connectors/aws/eventbridge/DefaultTestContext.scala	16
aws-event-bridge/src/test/scala/org/apache/pekko/stream/connectors/aws/eventbridge/EventBridgePublishMockSpec.scala	94
aws-event-bridge/src/test/scala/org/apache/pekko/stream/connectors/aws/eventbridge/IntegrationTestContext.scala	46
aws-spi-pekko-http/src/test/java/org/apache/pekko/stream/connectors/awsspi/s3/S3Test.java	108
aws-spi-pekko-http/src/test/resources/logback-test.xml	35
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/BaseAwsClientTest.scala	44
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClientH1TestSuite.scala	10
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClientSpec.scala	103
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/RequestRunnerSpec.scala	41
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/TestDynamoDB.scala	48
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/s3/TestS3.scala	149
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/sns/TestSNS.scala	32
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/sqs/TestSQS.scala	64
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/testcontainers/LocalStackReadyLogWaitStrategy.scala	22
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/testcontainers/TimeoutWaitStrategy.scala	9
awslambda/src/test/resources/logback-test.xml	23
azure-storage-queue/src/test/resources/logback-test.xml	23
cassandra/src/test/resources/logback-test.xml	29
cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionSpec.scala	122
cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraLifecycle.scala	85
cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionPerformanceSpec.scala	60
cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSpecBase.scala	22
couchbase/src/test/resources/logback-test.xml	26
couchbase/src/test/scala/org/apache/pekko/stream/connectors/couchbase/testing/CouchbaseSupport.scala	80
couchbase3/src/test/resources/logback-test.xml	26
couchbase3/src/test/scala/org/apache/pekko/stream/connectors/couchbase3/CouchbaseTestSupport.scala	69
csv/src/test/resources/logback-test.xml	23
csv/src/test/scala/org/apache/pekko/stream/connectors/csv/CsvFormatterSpec.scala	79
csv/src/test/scala/org/apache/pekko/stream/connectors/csv/CsvParserSpec.scala	302
doc-examples/src/test/java/org/apache/pekko/stream/connectors/eip/javadsl/PassThroughExamples.java	95
doc-examples/src/test/scala/org/apache/pekko/stream/connectors/eip/scaladsl/PassThroughExamples.scala	70
dynamodb/src/test/resources/logback-test.xml	23
dynamodb/src/test/scala/org/apache/pekko/stream/connectors/dynamodb/ItemSpec.scala	95
dynamodb/src/test/scala/org/apache/pekko/stream/connectors/dynamodb/TableSpec.scala	66
dynamodb/src/test/scala/org/apache/pekko/stream/connectors/dynamodb/TestOps.scala	177
elasticsearch/src/test/resources/log4j2-test.xml	13
elasticsearch/src/test/resources/logback-test.xml	27
elasticsearch/src/test/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchParamsSpec.scala	21
elasticsearch/src/test/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSimpleFlowStageTest.scala	79
elasticsearch/src/test/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourcStageTest.scala	42
file/src/test/resources/logback-test.xml	23
file/src/test/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveEntrySpec.scala	38
file/src/test/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlowTest.scala	41
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseFtpSupport.java	12
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseSftpSupport.java	29
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseSupport.java	10
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseSupportImpl.java	111
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/CommonFtpStageTest.java	119
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/FtpStageTest.java	62
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/FtpWithProxyStageTest.java	68
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/FtpsStageTest.java	60
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/FtpsWithProxyStageTest.java	68
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/KeyFileSftpSourceTest.java	49
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/PekkoSupport.java	7
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/RawKeySftpSourceTest.java	52
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/SftpStageTest.java	61
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/SftpWithProxyStageTest.java	67
ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/StrictHostCheckingSftpSourceTest.java	51
ftp/src/test/resources/id_rsa.pub	1
ftp/src/test/resources/logback-test.xml	29
ftp/src/test/resources/sftpd/init.sh	4
ftp/src/test/resources/sftpd/ssh_host_ed25519_key.pub	1
ftp/src/test/resources/sftpd/ssh_host_rsa_key.pub	1
ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseFtpSpec.scala	44
ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseFtpsSpec.scala	44
ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseSftpSpec.scala	45
ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/BaseSpec.scala	49
ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/CommonFtpStageSpec.scala	410
ftp/src/test/scala/org/apache/pekko/stream/connectors/ftp/FtpsWithTrustAndKeyManagersStageSpec.scala	57
geode/src/test/resources/logback-test.xml	24
geode/src/test/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PDXDecoderSpec.scala	35
geode/src/test/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PDXEncodeSpec.scala	27
geode/src/test/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxWriterMock.scala	47
google-cloud-bigquery-storage/src/test/java/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/AvroByteStringDecoder.scala	28
google-cloud-bigquery-storage/src/test/java/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorageSpec.java	56
google-cloud-bigquery-storage/src/test/resources/logback-test.xml	24
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSpecBase.scala	37
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/mock/BigQueryMockData.scala	94
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/mock/BigQueryMockServer.scala	93
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/ArrowByteStringDecoder.scala	49
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/AvroByteStringDecoder.scala	26
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorageSpec.scala	80
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorageSpec.scala	79
google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageSpec.scala	157
google-cloud-bigquery/src/test/java/org/apache/pekko/stream/connectors/googlecloud/bigquery/e2e/javadsl/BigQueryEndToEndTest.java	304
google-cloud-bigquery/src/test/resources/key.pub	6
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/HoverflySupport.scala	25
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/e2e/A.scala	59
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/e2e/javadsl/EndToEndHelper.scala	9
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/e2e/scaladsl/BigQueryEndToEndSpec.scala	143
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/e2e/scaladsl/EndToEndHelper.scala	34
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryQueriesSpec.scala	169
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BigQuerySchemasSpec.scala	48
google-cloud-bigquery/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryJsonProtocolSpec.scala	53
google-cloud-pub-sub-grpc/src/test/resources/logback-test.xml	23
google-cloud-pub-sub/src/test/resources/logback-test.xml	24
google-cloud-pub-sub/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/GooglePubSubSpec.scala	132
google-cloud-pub-sub/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/ModelSpec.scala	148
google-cloud-pub-sub/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApiSpec.scala	344
google-cloud-pub-sub/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/TestCredentials.scala	14
google-cloud-storage/src/test/resources/logback-test.xml	24
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCSExtSpec.scala	22
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCSSettingsSpec.scala	20
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageExtSpec.scala	39
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettingsSpec.scala	37
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/WithMaterializerGlobal.scala	22
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStreamIntegrationSpec.scala	263
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GoogleGCStorageStreamIntegrationSpec.scala	13
google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/scaladsl/GCStorageWiremockBase.scala	801
google-common/src/test/resources/key.pub	6
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/GoogleHttpException.scala	12
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/GoogleSettingsSpec.scala	51
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/HoverflySupport.scala	25
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/PaginatedRequestSpec.scala	84
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/ResumableUploadSpec.scala	73
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2Spec.scala	58
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/auth/OAuth2CredentialsSpec.scala	73
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttpSpec.scala	142
google-common/src/test/scala/org/apache/pekko/stream/connectors/google/util/AnnotateLastSpec.scala	34
google-fcm/src/test/resources/logback-test.xml	24
google-fcm/src/test/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/ConditionBuilderSpec.scala	28
google-fcm/src/test/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/FcmNotificationSpec.scala	33
google-fcm/src/test/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmSenderSpec.scala	96
hbase/src/test/resources/logback-test.xml	27
hdfs/src/test/resources/logback-test.xml	25
hdfs/src/test/scala/org/apache/pekko/stream/connectors/hdfs/util/TestUtils.scala	177
huawei-push-kit/src/test/resources/logback-test.xml	24
huawei-push-kit/src/test/scala/org/apache/pekko/stream/connectors/huawei/pushkit/ConditionBuilderSpec.scala	28
huawei-push-kit/src/test/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingsSpec.scala	11
huawei-push-kit/src/test/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/HmsTokenApiSpec.scala	79
huawei-push-kit/src/test/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitSenderSpec.scala	98
influxdb/src/test/resources/logback-test.xml	23
ironmq/src/test/java/org/apache/pekko/stream/connectors/ironmq/UnitTest.java	88
ironmq/src/test/java/org/apache/pekko/stream/connectors/ironmq/javadsl/IronMqConsumerTest.java	33
ironmq/src/test/resources/logback-test.xml	25
ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/IronMqSpec.scala	58
ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClientForTests.scala	25
ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClientSpec.scala	87
ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPullStageSpec.scala	21
ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPushStageSpec.scala	27
ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqConsumerSpec.scala	57
ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqProducerSpec.scala	65
jakartams/src/test/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsAckConnectorsTest.java	328
jakartams/src/test/resources/logback-test.xml	24
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/EmbeddedActiveMQServer.scala	13
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/JmsConnectionStatusSpec.scala	301
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerRetrySpec.scala	189
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/JmsSharedServerSpec.scala	27
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/JmsSpec.scala	68
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducerSpec.scala	131
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/impl/SoftReferenceCacheSpec.scala	95
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/CachedConnectionFactory.scala	16
jakartams/src/test/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsAckConnectorsSpec.scala	326
jms/src/test/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsAckConnectorsTest.java	323
jms/src/test/resources/logback-test.xml	24
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/JmsConnectionStatusSpec.scala	301
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/JmsProducerRetrySpec.scala	190
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/JmsSharedServerSpec.scala	24
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/JmsSpec.scala	67
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducerSpec.scala	130
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/impl/SoftReferenceCacheSpec.scala	95
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/scaladsl/CachedConnectionFactory.scala	16
jms/src/test/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsAckConnectorsSpec.scala	327
json-streaming/src/test/resources/logback-test.xml	23
kinesis/src/test/java/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisTest.java	71
kinesis/src/test/resources/logback-test.xml	23
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/DefaultTestContext.scala	25
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisFlowSpec.scala	130
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisMock.scala	16
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSourceSpec.scala	372
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSourceSpec.scala	162
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/ShardSettingsSpec.scala	25
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesis/Valve.scala	80
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesisfirehose/KinesisFirehoseFlowSpec.scala	87
kinesis/src/test/scala/org/apache/pekko/stream/connectors/kinesisfirehose/KinesisFirehoseMock.scala	16
kudu/src/test/resources/logback-test.xml	26
mongodb/src/test/resources/logback-test.xml	23
mqtt-streaming/src/test/resources/logback-test.xml	26
mqtt-streaming/src/test/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/MqttFrameStageSpec.scala	82
mqtt-streaming/src/test/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/QueueOfferStateSpec.scala	78
mqtt-streaming/src/test/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestStateSpec.scala	162
mqtt/src/test/resources/logback-test.xml	24
mqttv5/src/test/resources/logback-test.xml	24
orientdb/src/test/resources/logback-test.xml	24
pravega/src/test/java/org/apache/pekko/stream/connectors/pravega/PravegaGraphTestCase.java	78
pravega/src/test/java/org/apache/pekko/stream/connectors/pravega/PravegaKVTableTestCase.java	105
pravega/src/test/java/org/apache/pekko/stream/connectors/pravega/PravegaPekkoTestCaseSupport.java	12
pravega/src/test/resources/logback-test.xml	26
pravega/src/test/scala/org/apache/pekko/stream/connectors/pravega/PravegaBaseSpec.scala	69
pravega/src/test/scala/org/apache/pekko/stream/connectors/pravega/PravegaGraphSpec.scala	69
pravega/src/test/scala/org/apache/pekko/stream/connectors/pravega/PravegaKVTableSpec.scala	40
pravega/src/test/scala/org/apache/pekko/stream/connectors/pravega/PravegaStreamAndTableSpec.scala	90
reference/src/test/resources/logback-test.xml	24
s3/src/test/resources/logback-test.xml	26
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/MinioContainer.scala	19
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/MinioS3Test.scala	16
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/S3ExceptionSpec.scala	29
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/S3SettingsSpec.scala	223
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/TestUtils.scala	50
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/DiskBufferSpec.scala	70
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequestsSpec.scala	389
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/MarshallingSpec.scala	193
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/MemoryBufferSpec.scala	44
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/S3HeadersSpec.scala	117
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/S3StreamSpec.scala	146
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/SplitAfterSizeSpec.scala	100
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/auth/CanonicalRequestSpec.scala	146
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/auth/SignerSpec.scala	123
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/auth/SigningKeySpec.scala	26
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/auth/SplitAfterSizeWithContextSpec.scala	61
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/auth/StreamUtilsSpec.scala	69
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/auth/authSpec.scala	7
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/retry/Retry.scala	49
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/retry/Timeouts.scala	19
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/Generators.scala	82
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3ClientIntegrationSpec.scala	25
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3ExtSpec.scala	21
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala	1050
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3SlowMinioIntegrationSpec.scala	77
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3WireMockBase.scala	790
simple-codecs/src/test/resources/logback-test.xml	24
slick/src/test/resources/logback-test.xml	25
sns/src/test/resources/logback-test.xml	23
sns/src/test/scala/org/apache/pekko/stream/connectors/sns/DefaultTestContext.scala	16
sns/src/test/scala/org/apache/pekko/stream/connectors/sns/IntegrationTestContext.scala	55
sns/src/test/scala/org/apache/pekko/stream/connectors/sns/SnsPublishMockingSpec.scala	105
sns/src/test/travis/goaws.yaml	38
solr/src/test/resources/conf/schema.xml	54
solr/src/test/resources/conf/solrconfig.xml	102
solr/src/test/resources/logback-test.xml	27
spring-web/src/test/resources/logback-test.xml	23
sqs/src/test/java/org/apache/pekko/stream/connectors/sqs/javadsl/BaseSqsTest.java	71
sqs/src/test/resources/logback-test.xml	23
sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/SqsModelSpec.scala	102
sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/DefaultTestContext.scala	62
sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/MessageAttributeNameSpec.scala	31
sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSinkSpec.scala	220
sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSourceMockSpec.scala	118
sse/src/test/resources/logback-test.xml	23
text/src/test/resources/logback-test.xml	23
text/src/test/scala/org/apache/pekko/stream/connectors/text/scaladsl/CharsetCodingFlowsSpec.scala	145
udp/src/test/resources/logback-test.xml	23
unix-domain-socket/src/test/resources/logback-test.xml	23
xml/src/test/resources/logback-test.xml	23