Path Lines of Code actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/Effect.scala 140 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/internal/BehaviorTestKitImpl.scala 161 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/internal/StubbedActorContext.scala 171 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/Effects.scala 37 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala 28 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestProbe.scala 64 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/ActorTestKit.scala 148 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/BehaviorTestKit.scala 50 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/Effects.scala 28 actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala 26 actor-typed/src/main/scala/org/apache/pekko/actor/typed/ActorRef.scala 57 actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/ConsumerController.scala 152 actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/DurableProducerQueue.scala 148 actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/ProducerController.scala 122 actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/WorkPullingProducerController.scala 93 actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/ProducerControllerImpl.scala 698 actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala 567 actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/InterceptorImpl.scala 158 actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/LoggerClass.scala 49 actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/pubsub/TopicImpl.scala 116 actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/receptionist/LocalReceptionist.scala 195 actor/src/main/java/org/apache/pekko/actor/AbstractScheduler.java 34 actor/src/main/java/org/apache/pekko/dispatch/AbstractBoundedNodeQueue.java 143 actor/src/main/java/org/apache/pekko/japi/pf/ReceiveBuilder.java 124 actor/src/main/scala-2.12/org/apache/pekko/util/ByteString.scala 857 actor/src/main/scala-2.13/org/apache/pekko/util/ByteString.scala 885 actor/src/main/scala-3/org/apache/pekko/util/ByteString.scala 885 actor/src/main/scala/org/apache/pekko/actor/AbstractActor.scala 81 actor/src/main/scala/org/apache/pekko/actor/ActorPath.scala 246 actor/src/main/scala/org/apache/pekko/actor/ActorRef.scala 580 actor/src/main/scala/org/apache/pekko/actor/ActorRefProvider.scala 428 actor/src/main/scala/org/apache/pekko/actor/FSM.scala 450 actor/src/main/scala/org/apache/pekko/actor/FaultHandling.scala 300 actor/src/main/scala/org/apache/pekko/actor/TypedActor.scala 409 actor/src/main/scala/org/apache/pekko/dispatch/AbstractDispatcher.scala 370 actor/src/main/scala/org/apache/pekko/dispatch/BatchingExecutor.scala 79 actor/src/main/scala/org/apache/pekko/dispatch/Dispatchers.scala 217 actor/src/main/scala/org/apache/pekko/dispatch/Mailboxes.scala 252 actor/src/main/scala/org/apache/pekko/dispatch/VirtualThreadSupport.scala 83 actor/src/main/scala/org/apache/pekko/event/EventBus.scala 238 actor/src/main/scala/org/apache/pekko/event/Logging.scala 1037 actor/src/main/scala/org/apache/pekko/io/DnsProvider.scala 9 actor/src/main/scala/org/apache/pekko/io/SelectionHandler.scala 283 actor/src/main/scala/org/apache/pekko/io/dns/internal/RecordTypeSerializer.scala 16 actor/src/main/scala/org/apache/pekko/japi/JavaAPI.scala 127 actor/src/main/scala/org/apache/pekko/routing/SmallestMailbox.scala 103 actor/src/main/scala/org/apache/pekko/util/JavaVersion.scala 11 actor/src/main/scala/org/apache/pekko/util/LineNumbers.scala 283 actor/src/main/scala/org/apache/pekko/util/LockUtil.scala 60 actor/src/main/scala/org/apache/pekko/util/TypedMultiMap.scala 49 bench-jmh/src/main/scala/org/apache/pekko/remote/artery/compress/InvertCompressionTableBenchmark.scala 12 bench-jmh/src/main/scala/org/apache/pekko/stream/InterpreterBenchmark.scala 75 build.sbt 576 cluster-metrics/src/main/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRouting.scala 286 cluster-metrics/src/multi-jvm/scala/org/apache/pekko/cluster/metrics/ClusterMetricsExtensionSpec.scala 117 cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ClusterShardingSettings.scala 833 cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/ShardingProducerController.scala 136 cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/internal/ClusterShardingImpl.scala 353 cluster-sharding-typed/src/multi-jvm/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSpec.scala 86 cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/internal/AbstractLeastShardAllocationStrategy.scala 95 cluster-tools/src/main/scala/org/apache/pekko/cluster/client/ClusterClient.scala 669 cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala 861 cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/internal/ReplicatorBehavior.scala 182 cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/ClusterSingleton.scala 188 cluster-typed/src/multi-jvm/scala/org/apache/pekko/cluster/typed/MultiNodeTypedClusterSpec.scala 78 cluster/src/main/scala/org/apache/pekko/cluster/ClusterHeartbeat.scala 265 cluster/src/main/scala/org/apache/pekko/cluster/CrossDcClusterHeartbeat.scala 230 cluster/src/main/scala/org/apache/pekko/cluster/Reachability.scala 208 cluster/src/multi-jvm/scala/org/apache/pekko/cluster/MultiDcClusterSpec.scala 120 cluster/src/multi-jvm/scala/org/apache/pekko/cluster/NodeChurnSpec.scala 125 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/DeltaPropagationSelector.scala 149 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORMap.scala 385 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORMultiMap.scala 211 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/PNCounterMap.scala 94 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala 1946 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatorMessageSerializer.scala 493 multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Conductor.scala 417 multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Player.scala 293 persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/ExternalInteractions.scala 170 persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/Running.scala 802 persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/VersionVector.scala 166 persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/state/internal/DurableStateStoreInteractions.scala 77 persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/state/internal/Running.scala 209 persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/state/javadsl/Effect.scala 48 persistence/src/main/scala/org/apache/pekko/persistence/Persistent.scala 128 persistence/src/main/scala/org/apache/pekko/persistence/fsm/PersistentFSMBase.scala 395 persistence/src/main/scala/org/apache/pekko/persistence/journal/EventAdapter.scala 46 persistence/src/main/scala/org/apache/pekko/persistence/journal/EventAdapters.scala 134 persistence/src/main/scala/org/apache/pekko/persistence/journal/leveldb/SharedLeveldbStore.scala 64 persistence/src/main/scala/org/apache/pekko/persistence/state/DurableStateStoreRegistry.scala 61 project/Dependencies.scala 274 project/JdkOptions.scala 76 project/Paradox.scala 89 project/PekkoBuild.scala 266 project/SbtMultiJvmPlugin.scala 513 project/SigarLoader.scala 25 project/StreamOperatorsIndexGenerator.scala 235 project/TestQuickUntilPassed.scala 24 remote/src/main/java/org/apache/pekko/remote/artery/compress/CountMinSketch.java 162 remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala 980 remote/src/main/scala/org/apache/pekko/remote/RemoteActorRefProvider.scala 561 remote/src/main/scala/org/apache/pekko/remote/RemoteDaemon.scala 228 remote/src/main/scala/org/apache/pekko/remote/artery/ArteryTransport.scala 715 remote/src/main/scala/org/apache/pekko/remote/artery/Codecs.scala 638 remote/src/main/scala/org/apache/pekko/remote/artery/SystemMessageDelivery.scala 308 remote/src/main/scala/org/apache/pekko/remote/artery/aeron/AeronSink.scala 196 remote/src/main/scala/org/apache/pekko/remote/artery/aeron/AeronSource.scala 166 remote/src/main/scala/org/apache/pekko/remote/artery/aeron/ArteryAeronUdpTransport.scala 405 remote/src/main/scala/org/apache/pekko/remote/artery/compress/CompressionTable.scala 82 remote/src/main/scala/org/apache/pekko/remote/artery/compress/InboundCompressions.scala 389 remote/src/main/scala/org/apache/pekko/remote/artery/compress/TopHeavyHitters.scala 199 remote/src/main/scala/org/apache/pekko/remote/artery/tcp/ArteryTcpTransport.scala 399 remote/src/main/scala/org/apache/pekko/remote/transport/ThrottlerTransportAdapter.scala 468 remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala 481 serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/ActorRefModule.scala 39 serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala 418 serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/StreamRefModule.scala 69 stream-typed/src/main/scala/org/apache/pekko/stream/typed/scaladsl/ActorFlow.scala 74 stream/src/main/scala/org/apache/pekko/stream/ActorMaterializer.scala 564 stream/src/main/scala/org/apache/pekko/stream/impl/ActorProcessor.scala 241 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/Modules.scala 43 stream/src/main/scala/org/apache/pekko/stream/impl/PhasedFusingActorMaterializer.scala 741 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/fusing/ActorGraphInterpreter.scala 646 stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FlattenConcat.scala 283 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/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/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/streamref/StreamRefsMaster.scala 23 stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala 861 stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala 974 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/scaladsl/Compression.scala 21 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/Source.scala 340 stream/src/main/scala/org/apache/pekko/stream/scaladsl/StreamConverters.scala 93 stream/src/main/scala/org/apache/pekko/stream/scaladsl/Tcp.scala 280 stream/src/main/scala/org/apache/pekko/stream/snapshot/MaterializerState.scala 120 stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala 991