Path	Lines of Code
stream/src/main/java-jdk-9/org/apache/pekko/stream/javadsl/JavaFlowSupport.java	67
stream/src/main/java/org/apache/pekko/stream/javadsl/AsPublisher.java	5
stream/src/main/java/org/apache/pekko/stream/javadsl/FramingTruncation.java	5
stream/src/main/protobuf/StreamRefMessages.proto	48
stream/src/main/scala-2.12/org/apache/pekko/stream/javadsl/CollectionUtil.scala	13
stream/src/main/scala-2.13/org/apache/pekko/stream/javadsl/CollectionUtil.scala	13
stream/src/main/scala-3/org/apache/pekko/stream/javadsl/CollectionUtil.scala	13
stream/src/main/scala-jdk-9/org/apache/pekko/stream/impl/JavaFlowAndRsConverters.scala	145
stream/src/main/scala-jdk-9/org/apache/pekko/stream/scaladsl/JavaFlowSupport.scala	47
stream/src/main/scala/com/typesafe/sslconfig/pekko/PekkoSSLConfig.scala	114
stream/src/main/scala/com/typesafe/sslconfig/pekko/SSLEngineConfigurator.scala	23
stream/src/main/scala/com/typesafe/sslconfig/pekko/util/PekkoLoggerBridge.scala	20
stream/src/main/scala/org/apache/pekko/stream/ActorMaterializer.scala	564
stream/src/main/scala/org/apache/pekko/stream/Attributes.scala	323
stream/src/main/scala/org/apache/pekko/stream/BoundedSourceQueue.scala	11
stream/src/main/scala/org/apache/pekko/stream/CompletionStrategy.scala	12
stream/src/main/scala/org/apache/pekko/stream/FanInShape.scala	37
stream/src/main/scala/org/apache/pekko/stream/FanInShape1N.scala	29
stream/src/main/scala/org/apache/pekko/stream/FanOutShape.scala	37
stream/src/main/scala/org/apache/pekko/stream/FlowMonitor.scala	16
stream/src/main/scala/org/apache/pekko/stream/Graph.scala	34
stream/src/main/scala/org/apache/pekko/stream/IOResult.scala	39
stream/src/main/scala/org/apache/pekko/stream/KillSwitch.scala	146
stream/src/main/scala/org/apache/pekko/stream/MapAsyncPartitioned.scala	197
stream/src/main/scala/org/apache/pekko/stream/Materializer.scala	61
stream/src/main/scala/org/apache/pekko/stream/MaterializerLoggingProvider.scala	8
stream/src/main/scala/org/apache/pekko/stream/NeverMaterializedException.scala	5
stream/src/main/scala/org/apache/pekko/stream/OverflowStrategy.scala	63
stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala	25
stream/src/main/scala/org/apache/pekko/stream/RestartSettings.scala	87
stream/src/main/scala/org/apache/pekko/stream/Shape.scala	145
stream/src/main/scala/org/apache/pekko/stream/SslTlsOptions.scala	81
stream/src/main/scala/org/apache/pekko/stream/StreamDetachedException.scala	5
stream/src/main/scala/org/apache/pekko/stream/StreamLimitReachedException.scala	2
stream/src/main/scala/org/apache/pekko/stream/StreamRefSettings.scala	57
stream/src/main/scala/org/apache/pekko/stream/StreamRefs.scala	58
stream/src/main/scala/org/apache/pekko/stream/StreamTcpException.scala	7
stream/src/main/scala/org/apache/pekko/stream/StreamTimeoutException.scala	11
stream/src/main/scala/org/apache/pekko/stream/SubscriptionWithCancelException.scala	15
stream/src/main/scala/org/apache/pekko/stream/SubstreamCancelStrategy.scala	20
stream/src/main/scala/org/apache/pekko/stream/Supervision.scala	27
stream/src/main/scala/org/apache/pekko/stream/SystemMaterializer.scala	58
stream/src/main/scala/org/apache/pekko/stream/ThrottleMode.scala	9
stream/src/main/scala/org/apache/pekko/stream/TooManySubstreamsOpenException.scala	5
stream/src/main/scala/org/apache/pekko/stream/UniformFanInShape.scala	26
stream/src/main/scala/org/apache/pekko/stream/UniformFanOutShape.scala	22
stream/src/main/scala/org/apache/pekko/stream/WatchedActorTerminatedException.scala	4
stream/src/main/scala/org/apache/pekko/stream/impl/ActorMaterializerImpl.scala	207
stream/src/main/scala/org/apache/pekko/stream/impl/ActorProcessor.scala	241
stream/src/main/scala/org/apache/pekko/stream/impl/ActorPublisher.scala	90
stream/src/main/scala/org/apache/pekko/stream/impl/ActorRefBackpressureSinkStage.scala	83
stream/src/main/scala/org/apache/pekko/stream/impl/ActorRefBackpressureSource.scala	74
stream/src/main/scala/org/apache/pekko/stream/impl/ActorRefSinkStage.scala	52
stream/src/main/scala/org/apache/pekko/stream/impl/ActorRefSource.scala	133
stream/src/main/scala/org/apache/pekko/stream/impl/ActorSubscriberMessage.scala	17
stream/src/main/scala/org/apache/pekko/stream/impl/BoundedSourceQueue.scala	121
stream/src/main/scala/org/apache/pekko/stream/impl/Buffers.scala	153
stream/src/main/scala/org/apache/pekko/stream/impl/CompletedPublishers.scala	50
stream/src/main/scala/org/apache/pekko/stream/impl/ConstantFun.scala	26
stream/src/main/scala/org/apache/pekko/stream/impl/ContextPropagation.scala	17
stream/src/main/scala/org/apache/pekko/stream/impl/EmptySource.scala	18
stream/src/main/scala/org/apache/pekko/stream/impl/ExposedPublisherReceive.scala	21
stream/src/main/scala/org/apache/pekko/stream/impl/FailedSource.scala	20
stream/src/main/scala/org/apache/pekko/stream/impl/FanIn.scala	247
stream/src/main/scala/org/apache/pekko/stream/impl/FanOut.scala	258
stream/src/main/scala/org/apache/pekko/stream/impl/FanoutProcessor.scala	130
stream/src/main/scala/org/apache/pekko/stream/impl/JavaStreamSource.scala	35
stream/src/main/scala/org/apache/pekko/stream/impl/JsonObjectParser.scala	120
stream/src/main/scala/org/apache/pekko/stream/impl/LazySource.scala	66
stream/src/main/scala/org/apache/pekko/stream/impl/MaterializerGuardian.scala	43
stream/src/main/scala/org/apache/pekko/stream/impl/MaybeSource.scala	63
stream/src/main/scala/org/apache/pekko/stream/impl/Messages.scala	16
stream/src/main/scala/org/apache/pekko/stream/impl/Modules.scala	43
stream/src/main/scala/org/apache/pekko/stream/impl/PhasedFusingActorMaterializer.scala	741
stream/src/main/scala/org/apache/pekko/stream/impl/QueueSource.scala	196
stream/src/main/scala/org/apache/pekko/stream/impl/ReactiveStreamsCompliance.scala	102
stream/src/main/scala/org/apache/pekko/stream/impl/ResizableMultiReaderRingBuffer.scala	90
stream/src/main/scala/org/apache/pekko/stream/impl/RetryFlowCoordinator.scala	106
stream/src/main/scala/org/apache/pekko/stream/impl/SeqActorName.scala	14
stream/src/main/scala/org/apache/pekko/stream/impl/SetupStage.scala	110
stream/src/main/scala/org/apache/pekko/stream/impl/SingleConcat.scala	29
stream/src/main/scala/org/apache/pekko/stream/impl/SinkholeSubscriber.scala	23
stream/src/main/scala/org/apache/pekko/stream/impl/Sinks.scala	432
stream/src/main/scala/org/apache/pekko/stream/impl/Stages.scala	146
stream/src/main/scala/org/apache/pekko/stream/impl/StreamLayout.scala	372
stream/src/main/scala/org/apache/pekko/stream/impl/StreamSubscriptionTimeout.scala	79
stream/src/main/scala/org/apache/pekko/stream/impl/SubFlowImpl.scala	28
stream/src/main/scala/org/apache/pekko/stream/impl/SubscriberManagement.scala	180
stream/src/main/scala/org/apache/pekko/stream/impl/Throttle.scala	60
stream/src/main/scala/org/apache/pekko/stream/impl/Timers.scala	195
stream/src/main/scala/org/apache/pekko/stream/impl/Transfer.scala	134
stream/src/main/scala/org/apache/pekko/stream/impl/TraversalBuilder.scala	767
stream/src/main/scala/org/apache/pekko/stream/impl/Unfold.scala	130
stream/src/main/scala/org/apache/pekko/stream/impl/UnfoldResourceSource.scala	74
stream/src/main/scala/org/apache/pekko/stream/impl/UnfoldResourceSourceAsync.scala	111
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/ActorGraphInterpreter.scala	646
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/AggregateWithBoundary.scala	51
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/ArraySource.scala	31
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/CollectFirst.scala	42
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/CollectWhile.scala	40
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FlatMapPrefix.scala	156
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FlattenConcat.scala	283
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FutureFlow.scala	122
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala	421
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphStages.scala	372
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/IterableSource.scala	51
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/LazyFutureSource.scala	42
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/LazySingleSource.scala	30
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/MapConcat.scala	56
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala	1797
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala	662
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala	93
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/ZipWithIndex.scala	39
stream/src/main/scala/org/apache/pekko/stream/impl/io/ByteStringParser.scala	141
stream/src/main/scala/org/apache/pekko/stream/impl/io/FileOutputStage.scala	88
stream/src/main/scala/org/apache/pekko/stream/impl/io/IOSources.scala	109
stream/src/main/scala/org/apache/pekko/stream/impl/io/InputStreamSinkStage.scala	197
stream/src/main/scala/org/apache/pekko/stream/impl/io/InputStreamSource.scala	101
stream/src/main/scala/org/apache/pekko/stream/impl/io/OutputStreamGraphStage.scala	73
stream/src/main/scala/org/apache/pekko/stream/impl/io/OutputStreamSourceStage.scala	82
stream/src/main/scala/org/apache/pekko/stream/impl/io/TLSActor.scala	397
stream/src/main/scala/org/apache/pekko/stream/impl/io/TcpStages.scala	479
stream/src/main/scala/org/apache/pekko/stream/impl/io/TlsModule.scala	43
stream/src/main/scala/org/apache/pekko/stream/impl/io/compression/CompressionUtils.scala	33
stream/src/main/scala/org/apache/pekko/stream/impl/io/compression/Compressor.scala	12
stream/src/main/scala/org/apache/pekko/stream/impl/io/compression/DeflateCompressor.scala	58
stream/src/main/scala/org/apache/pekko/stream/impl/io/compression/DeflateDecompressor.scala	18
stream/src/main/scala/org/apache/pekko/stream/impl/io/compression/DeflateDecompressorBase.scala	35
stream/src/main/scala/org/apache/pekko/stream/impl/io/compression/GzipCompressor.scala	35
stream/src/main/scala/org/apache/pekko/stream/impl/io/compression/GzipDecompressor.scala	67
stream/src/main/scala/org/apache/pekko/stream/impl/package.scala	2
stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SinkRefImpl.scala	217
stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala	404
stream/src/main/scala/org/apache/pekko/stream/impl/streamref/StreamRefResolverImpl.scala	23
stream/src/main/scala/org/apache/pekko/stream/impl/streamref/StreamRefSettingsImpl.scala	21
stream/src/main/scala/org/apache/pekko/stream/impl/streamref/StreamRefsMaster.scala	23
stream/src/main/scala/org/apache/pekko/stream/impl/streamref/StreamRefsProtocol.scala	30
stream/src/main/scala/org/apache/pekko/stream/javadsl/BidiFlow.scala	71
stream/src/main/scala/org/apache/pekko/stream/javadsl/Compression.scala	21
stream/src/main/scala/org/apache/pekko/stream/javadsl/CoupledTerminationFlow.scala	7
stream/src/main/scala/org/apache/pekko/stream/javadsl/DelayStrategy.scala	47
stream/src/main/scala/org/apache/pekko/stream/javadsl/FileIO.scala	37
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala	861
stream/src/main/scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala	153
stream/src/main/scala/org/apache/pekko/stream/javadsl/Framing.scala	44
stream/src/main/scala/org/apache/pekko/stream/javadsl/Graph.scala	235
stream/src/main/scala/org/apache/pekko/stream/javadsl/Hub.scala	84
stream/src/main/scala/org/apache/pekko/stream/javadsl/JsonFraming.scala	8
stream/src/main/scala/org/apache/pekko/stream/javadsl/Keep.scala	19
stream/src/main/scala/org/apache/pekko/stream/javadsl/MergeLatest.scala	10
stream/src/main/scala/org/apache/pekko/stream/javadsl/Queue.scala	44
stream/src/main/scala/org/apache/pekko/stream/javadsl/RestartFlow.scala	83
stream/src/main/scala/org/apache/pekko/stream/javadsl/RestartSink.scala	54
stream/src/main/scala/org/apache/pekko/stream/javadsl/RestartSource.scala	100
stream/src/main/scala/org/apache/pekko/stream/javadsl/RetryFlow.scala	43
stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala	235
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala	974
stream/src/main/scala/org/apache/pekko/stream/javadsl/SourceWithContext.scala	147
stream/src/main/scala/org/apache/pekko/stream/javadsl/StreamConverters.scala	59
stream/src/main/scala/org/apache/pekko/stream/javadsl/StreamRefs.scala	8
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala	489
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala	479
stream/src/main/scala/org/apache/pekko/stream/javadsl/TLS.scala	77
stream/src/main/scala/org/apache/pekko/stream/javadsl/Tcp.scala	270
stream/src/main/scala/org/apache/pekko/stream/javadsl/package.scala	11
stream/src/main/scala/org/apache/pekko/stream/scaladsl/BidiFlow.scala	113
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Compression.scala	21
stream/src/main/scala/org/apache/pekko/stream/scaladsl/CoupledTerminationFlow.scala	34
stream/src/main/scala/org/apache/pekko/stream/scaladsl/DelayStrategy.scala	27
stream/src/main/scala/org/apache/pekko/stream/scaladsl/FileIO.scala	30
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala	976
stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContext.scala	100
stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContextOps.scala	104
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Framing.scala	293
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Graph.scala	1215
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Hub.scala	848
stream/src/main/scala/org/apache/pekko/stream/scaladsl/JsonFraming.scala	47
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Materialization.scala	12
stream/src/main/scala/org/apache/pekko/stream/scaladsl/MergeLatest.scala	53
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Queue.scala	55
stream/src/main/scala/org/apache/pekko/stream/scaladsl/RestartFlow.scala	260
stream/src/main/scala/org/apache/pekko/stream/scaladsl/RestartSink.scala	41
stream/src/main/scala/org/apache/pekko/stream/scaladsl/RestartSource.scala	66
stream/src/main/scala/org/apache/pekko/stream/scaladsl/RetryFlow.scala	37
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala	270
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala	340
stream/src/main/scala/org/apache/pekko/stream/scaladsl/SourceWithContext.scala	89
stream/src/main/scala/org/apache/pekko/stream/scaladsl/StreamConverters.scala	93
stream/src/main/scala/org/apache/pekko/stream/scaladsl/StreamRefs.scala	11
stream/src/main/scala/org/apache/pekko/stream/scaladsl/SubFlow.scala	11
stream/src/main/scala/org/apache/pekko/stream/scaladsl/TLS.scala	122
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Tcp.scala	280
stream/src/main/scala/org/apache/pekko/stream/scaladsl/package.scala	14
stream/src/main/scala/org/apache/pekko/stream/serialization/StreamRefSerializer.scala	140
stream/src/main/scala/org/apache/pekko/stream/snapshot/MaterializerState.scala	120
stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala	991
stream/src/main/scala/org/apache/pekko/stream/stage/StageLogging.scala	20