path	# lines of code
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/scaladsl/GoogleFcm.scala	21
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala	213
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/AndroidConfig.scala	108
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/NotificationTarget.scala	27
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/FcmNotification.scala	41
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/WebPushConfig.scala	14
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/BasicNotification.scala	12
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/ApnsConfig.scala	13
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/FcmResponse.scala	15
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/FcmOption.scala	22
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/scaladsl/GoogleFcm.scala	16
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/javadsl/GoogleFcm.scala	23
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala	218
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmSender.scala	39
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmFlows.scala	36
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/javadsl/GoogleFcm.scala	28
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala	147
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmJsonSupport.scala	66
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmSender.scala	45
google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmFlows.scala	63
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl/AvroParquetSource.scala	10
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl/AvroParquetFlow.scala	10
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl/AvroParquetSink.scala	12
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/javadsl/AvroParquetSource.scala	10
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/javadsl/AvroParquetFlow.scala	10
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/javadsl/AvroParquetSink.scala	13
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/impl/AvroParquetSource.scala	32
avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/impl/AvroParquetFlow.scala	40
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrSource.scala	11
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala	88
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrSink.scala	29
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/SolrMessages.scala	99
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrSource.scala	11
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala	98
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrSink.scala	40
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/SolrUpdateSettings.scala	17
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrFlowStage.scala	163
solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrSourceStage.scala	42
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/ForwardProxyPoolSettings.scala	22
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/AndroidConfig.scala	157
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/WebConfig.scala	55
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/Response.scala	15
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/NotificationTarget.scala	27
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/PushKitNotification.scala	25
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/BasicNotification.scala	10
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/ApnsConfig.scala	12
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/scaladsl/HmsPushKit.scala	14
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala	30
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/javadsl/HmsPushKit.scala	15
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/ForwardProxyHttpsContext.scala	42
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettings.scala	161
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala	193
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/HmsSession.scala	31
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitFlows.scala	26
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/HmsTokenApi.scala	49
huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitSender.scala	55
slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl/SlickWithTryResult.scala	34
slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl/Slick.scala	39
slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl/package.scala	9
slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala	135
slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/package.scala	45
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvFormatting.scala	32
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/ByteOrderMark.scala	10
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvQuotingStyle.scala	11
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvToMap.scala	59
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvParsing.scala	20
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/model.scala	5
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParsingStage.scala	53
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala	122
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvFormatter.scala	98
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala	324
csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala	95
csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/ByteOrderMark.java	13
csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvToMap.java	63
csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvParsing.java	30
csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvQuotingStyle.java	5
csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvFormatting.java	51
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala	572
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/Mqtt.scala	47
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/javadsl/MqttSession.scala	58
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/javadsl/Mqtt.scala	27
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttSessionSettings.scala	127
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala	712
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala	466
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/BehaviorRunner.scala	27
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ActorName.scala	10
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/QueueOfferState.scala	54
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala	808
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/MqttFrameStage.scala	69
mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala	608
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectNotFoundException.scala	2
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/scaladsl/GCStorage.scala	81
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/Owner.scala	18
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala	419
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/FailedUpload.scala	11
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala	27
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala	124
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/javadsl/GCStorage.scala	129
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageSettings.scala	22
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ProjectTeam.scala	16
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageExt.scala	17
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/settings.scala	42
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCSAttributes.scala	17
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCSExt.scala	13
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/Bucket.scala	83
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/CustomerEncryption.scala	17
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala	120
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala	224
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/BucketListResult.scala	22
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/RewriteResponse.scala	12
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/UploadPartResponse.scala	17
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala	298
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/MultiPartUpload.scala	4
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/BucketInfo.scala	4
unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala	55
unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/javadsl/UnixDomainSocket.scala	67
unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/UnixSocketAddress.scala	11
unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala	439
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorage.scala	76
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/GrpcBigQueryStorageReader.scala	27
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala	92
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageAttributes.scala	10
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorage.scala	76
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSettings.scala	46
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala	154
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala	105
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala	163
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/ProtobufConverters.scala	35
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryRecordMapImpl.scala	25
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AkkaGrpcSettings.scala	57
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/ArrowSource.scala	70
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AvroSource.scala	32
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AvroDecoder.scala	37
google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/SDKClientSource.scala	19
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/jwt/JwtSprayJson.scala	56
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/scaladsl/Google.scala	21
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/scaladsl/Paginated.scala	4
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/scaladsl/`X-Upload-Content-Type`.scala	25
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/util/Retry.scala	46
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/util/EitherFlow.scala	23
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/util/AnnotateLast.scala	39
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/implicits.scala	50
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/ResumableUpload.scala	163
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleAttributes.scala	16
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/javadsl/Google.scala	32
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/javadsl/Paginated.scala	13
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala	30
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala	205
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/ForwardProxyPoolSettings.scala	44
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/ForwardProxyHttpsContext.scala	29
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala	119
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/PaginatedRequest.scala	48
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/AccessToken.scala	29
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2Exception.scala	36
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2Credentials.scala	34
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/ServiceAccountCredentials.scala	52
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/UserAccessCredentials.scala	58
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/ComputeEngineCredentials.scala	24
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleComputeMetadata.scala	50
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/UserAccessMetadata.scala	37
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/OAuth2Credentials.scala	58
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala	78
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/NoCredentials.scala	28
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2.scala	53
google-common/src/main/java/org/apache/pekko/stream/connectors/google/javadsl/XUploadContentType.java	9
json-streaming/src/main/scala/org/apache/pekko/stream/connectors/json/scaladsl/JsonReader.scala	12
json-streaming/src/main/scala/org/apache/pekko/stream/connectors/json/javadsl/JsonReader.scala	12
json-streaming/src/main/scala/org/apache/pekko/stream/connectors/json/impl/JsonStreamReader.scala	57
text/src/main/scala/org/apache/pekko/stream/connectors/text/scaladsl/TextFlow.scala	16
text/src/main/scala/org/apache/pekko/stream/connectors/text/javadsl/TextFlow.scala	15
text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetDecodingFlow.scala	15
text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetTranscodingFlow.scala	16
text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetLogic.scala	136
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/CommittableReadResult.scala	10
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpRpcFlow.scala	25
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpSink.scala	15
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpSource.scala	16
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlow.scala	28
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlowWithContext.scala	16
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/CommittableReadResult.scala	15
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpRpcFlow.scala	37
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSink.scala	19
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSource.scala	16
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlow.scala	37
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlowWithContext.scala	22
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/model.scala	79
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala	289
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala	192
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala	64
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSimpleFlowStage.scala	37
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala	153
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala	148
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpConnectorLogic.scala	60
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncUnorderedFlowStage.scala	37
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala	48
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncFlowStage.scala	51
amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala	315
csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala	64
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala	141
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala	203
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/StringEnum.scala	20
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/ErrorProtoJsonProtocol.scala	37
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/JobJsonProtocol.scala	200
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/DatasetJsonProtocol.scala	73
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/QueryJsonProtocol.scala	225
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryStandardFormats.scala	6
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryBytes.scala	8
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryRestJsonProtocol.scala	9
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryProductFormats.scala	17
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryRestBasicFormats.scala	33
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryJsonFormat.scala	16
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryNumber.scala	6
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryJsonProtocol.scala	11
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryCollectionFormats.scala	47
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryJavaTimeFormats.scala	55
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryBasicFormats.scala	123
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTables.scala	60
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryDatasets.scala	62
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BasicSchemas.scala	20
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/CollectionSchemas.scala	19
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/ProductSchemas.scala	20
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/StandardSchemas.scala	8
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/Schema.scala	6
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/SchemaWriter.scala	21
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BigQuerySchemas.scala	8
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/PrimitiveSchemaWriter.scala	11
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/JavaTimeSchemas.scala	14
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryQueries.scala	110
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryRest.scala	24
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQuery.scala	10
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala	114
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala	105
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/InsertAllRetryPolicy.scala	22
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryException.scala	60
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/jackson/BigQueryMarshallers.scala	39
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala	188
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryEndpoints.scala	26
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala	31
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQuerySettings.scala	26
google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryAttributes.scala	17
file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/Archive.scala	28
file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/FileTailSource.scala	25
file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/Directory.scala	38
file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/LogRotatorSink.scala	165
file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/DirectoryChangesSource.scala	19
file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl/Archive.scala	54
file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl/LogRotatorSink.scala	46
file/src/main/scala/org/apache/pekko/stream/connectors/file/model.scala	122
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipReaderSource.scala	83
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala	69
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/EnsureByteStreamSize.scala	34
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveManager.scala	20
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarReaderStage.scala	224
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveEntry.scala	115
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/FileByteStringSeparators.scala	27
file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveManager.scala	20
file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/FileTailSource.java	35
file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/Directory.java	27
file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/DirectoryChangesSource.java	18
file/src/main/java/org/apache/pekko/stream/connectors/file/DirectoryChange.java	6
file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java	110
file/src/main/java/org/apache/pekko/stream/connectors/file/impl/DirectoryChangesSource.java	165
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqConsumer.scala	15
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqProducer.scala	51
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/CommittableMessage.scala	11
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/IronMqConsumer.scala	12
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/IronMqProducer.scala	71
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/CommittableMessage.scala	11
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/javadsl/package.scala	35
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/domain.scala	16
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/IronMqSettings.scala	96
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClient.scala	190
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/Codec.scala	55
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/ReservedMessage.scala	18
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPullStage.scala	86
ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPushStage.scala	63
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/scaladsl/AzureQueueSource.scala	13
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/scaladsl/AzureQueueSink.scala	33
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/javadsl/AzureQueueSource.scala	14
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/javadsl/AzureQueueSink.scala	36
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/settings.scala	30
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/model.scala	16
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSinkFunctions.scala	23
azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala	53
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/DocumentUpdate.scala	17
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoSource.scala	9
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoSink.scala	41
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoFlow.scala	53
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSource.scala	9
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSink.scala	51
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoFlow.scala	66
mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/DocumentReplace.scala	17
project/CopyrightHeader.scala	100
project/AutomaticModuleName.scala	7
project/TestChanged.scala	40
project/PekkoHttpDependency.scala	6
project/Dependencies.scala	437
project/plugins.sbt	19
project/LicenseReport.scala	41
project/CopyrightHeaderForBuild.scala	17
project/Common.scala	101
project/MetaInfLicenseNoticeCopy.scala	22
project/PekkoCoreDependency.scala	6
aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala	202
aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpAsyncHttpService.scala	6
aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/RequestRunner.scala	52
aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/TestBase.scala	23
aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/DynamoDBITTest.scala	62
aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/kinesis/KinesisITTest.scala	72
aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala	44
aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3/S3ITTest.scala	102
simple-codecs/src/main/scala/org/apache/pekko/stream/connectors/recordio/scaladsl/RecordIOFraming.scala	10
simple-codecs/src/main/scala/org/apache/pekko/stream/connectors/recordio/javadsl/RecordIOFraming.scala	11
simple-codecs/src/main/scala/org/apache/pekko/stream/connectors/recordio/impl/RecordIOFramingStage.scala	90
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsExceptions.scala	38
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsProducerSettings.scala	97
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsConnectorState.scala	33
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsConsumer.scala	62
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsProducer.scala	49
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/package.scala	22
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/AcknowledgeMode.scala	38
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Headers.scala	68
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsSettings.scala	12
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala	501
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Envelopes.scala	15
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumer.scala	45
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducer.scala	66
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Credentials.scala	45
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/ConnectionRetrySettings.scala	70
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/SendRetrySettings.scala	58
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsBrowseSettings.scala	76
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala	142
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConsumerStage.scala	47
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala	332
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala	202
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsTxSourceStage.scala	65
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsInternalMatValues.scala	10
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/Sessions.scala	88
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SourceStageLogic.scala	115
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageReader.scala	60
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/InternalConnectionState.scala	21
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsAckSourceStage.scala	62
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SoftReferenceCache.scala	26
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/GraphStageCompanion.scala	14
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsBrowseStage.scala	52
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala	103
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Destinations.scala	29
jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java	10
jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducerStatus.java	6
jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumerControl.java	7
kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/scaladsl/KuduTable.scala	23
kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduTableSettings.scala	47
kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduClientExt.scala	20
kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduAttributes.scala	10
kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/javadsl/KuduTable.scala	13
kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/impl/KuduFlowStage.scala	63
kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/impl/KuduCapabilities.scala	19
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ReadResult.scala	25
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchSource.scala	81
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchSink.scala	12
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchFlow.scala	137
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchSourceSettings.scala	40
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteSettingsBase.scala	23
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchWriteSettings.scala	75
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchParams.scala	4
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteMessage.scala	121
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchSourceSettings.scala	40
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala	123
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSink.scala	16
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchFlow.scala	73
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/testkit/MessageFactory.scala	35
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala	37
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala	77
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchWriteSettings.scala	35
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchConnectionSettings.scala	7
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV7.scala	52
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala	265
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSimpleFlowStage.scala	124
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV5.scala	59
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/NDJsonProtocol.scala	7
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchApi.scala	22
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApi.scala	50
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchParams.scala	16
elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/OpensearchApiVersion.java	4
elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/ApiVersionBase.java	2
elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/ApiVersion.java	5
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala	175
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala	313
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala	327
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpBrowserGraphStage.scala	62
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpsOperations.scala	48
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpLike.scala	39
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpGraphStage.scala	16
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala	196
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpDirectoryOperationsGraphStage.scala	26
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpGraphStageLogic.scala	55
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/SftpOperations.scala	169
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala	292
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/CommonFtpOperations.scala	85
ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpOperations.scala	44
ftp/src/main/java/org/apache/commons/net/ftp/LegacyFtpsClient.java	121
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala	47
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala	47
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala	85
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/PubSubAttributes.scala	11
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala	44
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala	45
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala	94
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/PubSubAttributes.scala	11
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/impl/PekkoGrpcSettings.scala	34
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/impl/DeprecatedCredentials.scala	12
google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/PubSubSettings.scala	61
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsSource.scala	43
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala	124
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsSource.scala	40
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala	123
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/model.scala	106
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/HdfsFlowStage.scala	169
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/strategy/DefaultRotationStrategy.scala	38
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/strategy/Strategy.scala	9
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/strategy/DefaultSyncStrategy.scala	19
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/writer/DataWriter.scala	32
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/writer/CompressedDataWriter.scala	51
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/writer/SequenceWriter.scala	66
hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/writer/HdfsWriter.scala	35
spring-web/src/main/java/org/apache/pekko/stream/connectors/spring/web/SpringWebPekkoStreamsProperties.java	12
spring-web/src/main/java/org/apache/pekko/stream/connectors/spring/web/PekkoStreamsRegistrar.java	35
spring-web/src/main/java/org/apache/pekko/stream/connectors/spring/web/SpringWebPekkoStreamsConfiguration.java	45
aws-event-bridge/src/main/scala/org/apache/pekko/stream/connectors/aws/eventbridge/scaladsl/EventBridgePublisher.scala	39
aws-event-bridge/src/main/scala/org/apache/pekko/stream/connectors/aws/eventbridge/javadsl/EventBridgePublisher.scala	50
aws-event-bridge/src/main/scala/org/apache/pekko/stream/connectors/aws/eventbridge/EventBridgePublishSettings.scala	15
geode/scripts/cache.xml	23
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/scaladsl/Geode.scala	61
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala	5
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/GeodeSettings.scala	38
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeFiniteSourceStage.scala	33
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeFlowStage.scala	40
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeQueryGraphLogic.scala	21
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeContinuousSourceStage.scala	44
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeSourceStageLogic.scala	22
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeCQueryGraphLogic.scala	80
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/DelegatingPdxSerializer.scala	29
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/ShapelessPdxSerializer.scala	21
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala	172
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxDecoder.scala	104
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/GeodeCache.scala	20
geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/GeodeCapabilities.scala	24
geode/src/main/java/org/apache/pekko/stream/connectors/geode/javadsl/Geode.java	44
geode/src/main/java/org/apache/pekko/stream/connectors/geode/javadsl/GeodeWithPoolSubscription.java	33
geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx/LabelledGenericGeneric.scala	37
geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx/ObjectDecoder.scala	26
geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx/ObjectEncoder.scala	23
geode/src/main/scala-2/org/apache/pekko/stream/connectors/geode/impl/pdx/ObjectDecoder.scala	28
geode/src/main/scala-2/org/apache/pekko/stream/connectors/geode/impl/pdx/ObjectEncoder.scala	26
sns/src/main/scala/org/apache/pekko/stream/connectors/sns/scaladsl/SnsPublisher.scala	41
sns/src/main/scala/org/apache/pekko/stream/connectors/sns/javadsl/SnsPublisher.scala	51
sns/src/main/scala/org/apache/pekko/stream/connectors/sns/SnsPublishSettings.scala	15
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/scaladsl/InfluxDbSink.scala	21
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/scaladsl/InfluxDbFlow.scala	28
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/scaladsl/InfluxDbSource.scala	21
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/javadsl/InfluxDbSink.scala	26
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/javadsl/InfluxDbFlow.scala	52
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/javadsl/InfluxDbSource.scala	21
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/InfluxDbReadSettings.scala	17
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/InfluxDbFlowStage.scala	111
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/PekkoConnectorsResultMapperHelper.scala	223
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/InfluxDbSourceStage.scala	115
influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/InfluxDbWriteMessage.scala	49
awslambda/src/main/scala/org/apache/pekko/stream/connectors/awslambda/scaladsl/AwsLambdaFlow.scala	12
awslambda/src/main/scala/org/apache/pekko/stream/connectors/awslambda/javadsl/AwsLambdaFlow.scala	10
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsExceptions.scala	38
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala	97
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConnectorState.scala	33
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConsumer.scala	63
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsProducer.scala	49
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/package.scala	22
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/AcknowledgeMode.scala	38
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Headers.scala	68
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsSettings.scala	13
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala	501
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Envelopes.scala	16
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConsumer.scala	45
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsProducer.scala	66
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Credentials.scala	45
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/ConnectionRetrySettings.scala	70
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/SendRetrySettings.scala	58
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala	77
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala	142
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConsumerStage.scala	47
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConnector.scala	332
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala	203
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala	66
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsInternalMatValues.scala	10
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/Sessions.scala	88
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala	115
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala	60
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/InternalConnectionState.scala	21
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala	62
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SoftReferenceCache.scala	26
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/GraphStageCompanion.scala	14
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsBrowseStage.scala	52
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala	103
jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Destinations.scala	30
jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConnectorState.java	10
jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsProducerStatus.java	6
jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConsumerControl.java	7
dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/scaladsl/DynamoDb.scala	43
dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala	43
dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/javadsl/DynamoDb.scala	48
sse/src/main/scala/org/apache/pekko/stream/connectors/sse/scaladsl/EventSource.scala	67
sse/src/main/scala/org/apache/pekko/stream/connectors/sse/javadsl/EventSource.scala	46
testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala	48
testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/Repeated.scala	19
testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala	41
testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl/LogCapturingJunit4.scala	35
testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/LogbackUtil.scala	36
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/KinesisFirehoseErrors.scala	10
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/scaladsl/KinesisFirehoseFlow.scala	34
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/scaladsl/KinesisFirehoseSink.scala	12
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/KinesisFirehoseFlowSettings.scala	43
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/javadsl/KinesisFirehoseFlow.scala	16
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/javadsl/KinesisFirehoseSink.scala	15
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSchedulerSource.scala	50
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSource.scala	27
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSink.scala	24
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala	104
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/ShardSettings.scala	74
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/KinesisFlowSettings.scala	45
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/CommittableRecord.scala	40
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerSettings.scala	36
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/KinesisErrors.scala	17
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisSchedulerSource.scala	39
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisSource.scala	15
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisSink.scala	15
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisFlow.scala	33
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/KinesisSchedulerErrors.scala	5
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/ShardIterator.scala	47
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSourceStage.scala	130
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala	95
kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/ShardProcessor.scala	64
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaReaderGroupManager.scala	25
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/scaladsl/Pravega.scala	20
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/scaladsl/PravegaTable.scala	34
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaEvent.scala	3
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala	436
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/TableEntry.scala	4
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaWriter.scala	13
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableSource.scala	127
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaCapabilities.scala	19
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaSource.scala	102
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableWriteFlow.scala	118
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableReadFlow.scala	102
pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaFlow.scala	94
pravega/src/main/java/org/apache/pekko/stream/connectors/pravega/javadsl/Pravega.java	37
pravega/src/main/java/org/apache/pekko/stream/connectors/pravega/javadsl/PravegaTable.java	44
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/scaladsl/XmlParsing.scala	31
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/scaladsl/XmlWriting.scala	18
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/javadsl/XmlParsing.scala	30
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/javadsl/XmlWriting.scala	21
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/model.scala	124
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl/Subtree.scala	108
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl/Coalesce.scala	43
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl/Subslice.scala	76
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl/StreamingXmlWriter.scala	84
xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl/StreamingXmlParser.scala	94
xml/src/main/java/org/apache/pekko/stream/connectors/xml/ParseEventMarker.java	11
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttSink.scala	12
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttMessageWithAck.scala	19
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttSource.scala	19
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttFlow.scala	41
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttSink.scala	13
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttMessageWithAck.scala	20
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttSource.scala	24
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttFlow.scala	37
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala	211
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala	45
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala	297
mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala	65
build.sbt	426
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseSessionRegistry.scala	56
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseSession.scala	75
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala	154
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseSource.scala	31
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseSink.scala	23
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/DiscoverySupport.scala	58
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseSession.scala	76
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseFlow.scala	52
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseSource.scala	18
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseSink.scala	39
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala	167
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseResponseException.scala	13
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/RxUtilities.scala	54
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionImpl.scala	134
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseClusterRegistry.scala	46
couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionJavaAdapter.scala	82
couchbase/src/main/java/org/apache/pekko/stream/connectors/couchbase/javadsl/DiscoverySupport.java	32
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/scaladsl/Reference.scala	29
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/javadsl/Reference.scala	25
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala	51
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/settings.scala	55
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/testkit/MessageFactory.scala	29
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/model.scala	68
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceFlowStage.scala	37
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceWithResourceFlowStage.scala	39
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceSourceStage.scala	39
reference/src/main/scala/org/apache/pekko/stream/connectors/reference/attributes.scala	9
hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/scaladsl/HTableStage.scala	16
hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/javadsl/HTableStage.scala	17
hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/HTableSettings.scala	49
hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/impl/HBaseSourceStage.scala	48
hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/impl/HBaseCapabilities.scala	45
hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/impl/HBaseFlowStage.scala	58
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraServerMetaData.scala	6
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraFlow.scala	72
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSource.scala	14
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala	143
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala	58
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraSessionSettings.scala	36
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraWriteSettings.scala	36
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraFlow.scala	40
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSource.scala	16
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala	83
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala	23
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/DriverConfigLoaderFromConfig.scala	23
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraMetricsRegistry.scala	24
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala	46
cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CqlSessionProvider.scala	59
udp/src/main/scala/org/apache/pekko/stream/connectors/udp/scaladsl/Udp.scala	45
udp/src/main/scala/org/apache/pekko/stream/connectors/udp/javadsl/Udp.scala	46
udp/src/main/scala/org/apache/pekko/stream/connectors/udp/model.scala	20
udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpBind.scala	78
udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpSend.scala	55
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsBatchException.scala	16
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala	178
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSource.scala	48
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSink.scala	50
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckSink.scala	15
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala	96
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsPublishBatchSettings.scala	14
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsPublishSettings.scala	15
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsSourceSettings.scala	128
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsAckBatchSettings.scala	15
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsAckGroupedSettings.scala	48
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsPublishGroupedSettings.scala	36
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsAckFlow.scala	18
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsSource.scala	11
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishSink.scala	58
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsAckSink.scala	24
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala	42
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/testkit/MessageFactory.scala	40
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsModel.scala	203
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/impl/BalancingMapAsync.scala	95
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsAckSettings.scala	20
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala	15
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttMessageWithAck.scala	19
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala	22
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala	46
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala	16
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala	19
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala	26
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala	36
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala	330
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala	47
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala	429
mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala	72
couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseFlow.scala	166
couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseSource.scala	103
couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseSink.scala	38
couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/javadsl/CouchbaseFlow.scala	105
couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/javadsl/CouchbaseSource.scala	69
couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/javadsl/CouchbaseSink.scala	40
couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/Document.scala	12
google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/scaladsl/GooglePubSub.scala	81
google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/javadsl/GooglePubSub.scala	60
google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala	222
google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala	233
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/OrientDbSourceSettings.scala	32
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/scaladsl/OrientDbSource.scala	27
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/scaladsl/OrientDbFlow.scala	53
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/scaladsl/OrientDbSink.scala	21
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/javadsl/OrientDbSource.scala	33
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/javadsl/OrientDbFlow.scala	52
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/javadsl/OrientDbSink.scala	24
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/OrientDbWriteSettings.scala	22
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/model.scala	12
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/impl/OrientDbSourceStage.scala	92
orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/impl/OrientDbFlowStage.scala	101
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Exception.scala	31
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala	13
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala	417
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Ext.scala	13
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Attributes.scala	17
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/headers/StorageClass.scala	14
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/headers/ServerSideEncryption.scala	121
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/headers/CannedAcl.scala	17
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala	659
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala	499
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Headers.scala	93
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala	936
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/Chunk.scala	18
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Request.scala	16
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/MemoryWithContext.scala	37
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/SplitAfterSizeWithContext.scala	36
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/DiskBuffer.scala	72
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/MemoryBuffer.scala	31
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/SplitAfterSize.scala	56
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/Marshalling.scala	259
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala	1288
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala	305
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/CanonicalRequest.scala	75
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/Signer.scala	54
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/SigningKey.scala	42
s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/package.scala	30
mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala	101
mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala	113