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-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	562
stream/src/main/scala/org/apache/pekko/stream/Attributes.scala	323
stream/src/main/scala/org/apache/pekko/stream/BoundedSourceQueue.scala	10
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	152
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	24
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/SubscriptionWithCancelException.scala	15
stream/src/main/scala/org/apache/pekko/stream/SubstreamCancelStrategy.scala	11
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	204
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	136
stream/src/main/scala/org/apache/pekko/stream/impl/ActorSubscriberMessage.scala	17
stream/src/main/scala/org/apache/pekko/stream/impl/BoundedSourceQueue.scala	120
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	32
stream/src/main/scala/org/apache/pekko/stream/impl/JsonObjectParser.scala	118
stream/src/main/scala/org/apache/pekko/stream/impl/LazySource.scala	70
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	730
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	140
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	194
stream/src/main/scala/org/apache/pekko/stream/impl/Transfer.scala	134
stream/src/main/scala/org/apache/pekko/stream/impl/TraversalBuilder.scala	728
stream/src/main/scala/org/apache/pekko/stream/impl/Unfold.scala	103
stream/src/main/scala/org/apache/pekko/stream/impl/UnfoldResourceSource.scala	71
stream/src/main/scala/org/apache/pekko/stream/impl/UnfoldResourceSourceAsync.scala	110
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/ActorGraphInterpreter.scala	649
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/AggregateWithBoundary.scala	51
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FlatMapPrefix.scala	157
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	414
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphStages.scala	363
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/Ops.scala	1768
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala	657
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	478
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	49
stream/src/main/scala/org/apache/pekko/stream/javadsl/FileIO.scala	37
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala	801
stream/src/main/scala/org/apache/pekko/stream/javadsl/FlowWithContext.scala	130
stream/src/main/scala/org/apache/pekko/stream/javadsl/Framing.scala	44
stream/src/main/scala/org/apache/pekko/stream/javadsl/Graph.scala	216
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	199
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala	894
stream/src/main/scala/org/apache/pekko/stream/javadsl/SourceWithContext.scala	127
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	442
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala	432
stream/src/main/scala/org/apache/pekko/stream/javadsl/TLS.scala	77
stream/src/main/scala/org/apache/pekko/stream/javadsl/Tcp.scala	271
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	29
stream/src/main/scala/org/apache/pekko/stream/scaladsl/FileIO.scala	30
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala	862
stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContext.scala	51
stream/src/main/scala/org/apache/pekko/stream/scaladsl/FlowWithContextOps.scala	84
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Framing.scala	293
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Graph.scala	1216
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Hub.scala	837
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	234
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala	286
stream/src/main/scala/org/apache/pekko/stream/scaladsl/SourceWithContext.scala	41
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	965
stream/src/main/scala/org/apache/pekko/stream/stage/StageLogging.scala	20