Path Lines of Code actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/AsyncTestingExampleTest.java 139 actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/JunitIntegrationExampleTest.java 20 actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/LogCapturingExampleTest.java 20 actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/ManualTimerExampleTest.java 42 actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/SyncTestingExampleTest.java 153 actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/TestConfigExample.java 13 actor-testkit-typed/src/test/java/org/apache/pekko/actor/testkit/typed/javadsl/ActorTestKitApiTest.java 78 actor-testkit-typed/src/test/java/org/apache/pekko/actor/testkit/typed/javadsl/ActorTestKitTest.java 49 actor-testkit-typed/src/test/java/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKitTest.java 329 actor-testkit-typed/src/test/java/org/apache/pekko/actor/testkit/typed/javadsl/LoggingTestKitTest.java 67 actor-testkit-typed/src/test/java/org/apache/pekko/actor/testkit/typed/javadsl/TestProbeTest.java 108 actor-testkit-typed/src/test/resources/logback-test.xml 19 actor-testkit-typed/src/test/scala/org/apache/pekko/actor/testkit/typed/scaladsl/ActorTestKitSpec.scala 139 actor-testkit-typed/src/test/scala/org/apache/pekko/actor/testkit/typed/scaladsl/BehaviorTestKitSpec.scala 441 actor-testkit-typed/src/test/scala/org/apache/pekko/actor/testkit/typed/scaladsl/LoggingEventFilterSpec.scala 121 actor-testkit-typed/src/test/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestAppenderSpec.scala 96 actor-testkit-typed/src/test/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestProbeSpec.scala 144 actor-tests/src/test/java/org/apache/pekko/actor/AbstractFSMActorTest.java 35 actor-tests/src/test/java/org/apache/pekko/actor/ActorCreationTest.java 289 actor-tests/src/test/java/org/apache/pekko/actor/ActorSelectionTest.java 25 actor-tests/src/test/java/org/apache/pekko/actor/ActorSystemTest.java 29 actor-tests/src/test/java/org/apache/pekko/actor/AddressTest.java 13 actor-tests/src/test/java/org/apache/pekko/actor/JavaAPI.java 162 actor-tests/src/test/java/org/apache/pekko/actor/JavaAPITestActor.java 8 actor-tests/src/test/java/org/apache/pekko/actor/JavaExtension.java 62 actor-tests/src/test/java/org/apache/pekko/actor/NonPublicClass.java 12 actor-tests/src/test/java/org/apache/pekko/actor/NonStaticCreator.java 8 actor-tests/src/test/java/org/apache/pekko/actor/StashJavaAPI.java 34 actor-tests/src/test/java/org/apache/pekko/actor/StashJavaAPITestActors.java 61 actor-tests/src/test/java/org/apache/pekko/actor/TestAnnotation.java 8 actor-tests/src/test/java/org/apache/pekko/actor/setup/ActorSystemSetupTest.java 21 actor-tests/src/test/java/org/apache/pekko/dispatch/JavaFutureTests.java 275 actor-tests/src/test/java/org/apache/pekko/event/ActorWithMDC.java 50 actor-tests/src/test/java/org/apache/pekko/event/LoggingAdapterTest.java 136 actor-tests/src/test/java/org/apache/pekko/japi/JavaAPITestBase.java 64 actor-tests/src/test/java/org/apache/pekko/japi/MatchBuilderTest.java 85 actor-tests/src/test/java/org/apache/pekko/japi/ThrowablesTest.java 16 actor-tests/src/test/java/org/apache/pekko/japi/pf/PFBuilderTest.java 19 actor-tests/src/test/java/org/apache/pekko/japi/pf/ReceiveBuilderTest.java 228 actor-tests/src/test/java/org/apache/pekko/pattern/CircuitBreakerTest.java 55 actor-tests/src/test/java/org/apache/pekko/pattern/PatternsTest.java 395 actor-tests/src/test/java/org/apache/pekko/pattern/StatusReplyTest.java 87 actor-tests/src/test/java/org/apache/pekko/util/ByteStringTest.java 19 actor-tests/src/test/java/org/apache/pekko/util/JavaDuration.java 16 actor-tests/src/test/java/org/apache/pekko/util/LineNumberSpecCodeForJava.java 25 actor-tests/src/test/scala-2/org/apache/pekko/util/LineNumberSpec.scala 37 actor-tests/src/test/scala-2/org/apache/pekko/util/TypedMultiMapSpec.scala 54 actor-tests/src/test/scala-3/org/apache/pekko/util/LineNumberSpec.scala 37 actor-tests/src/test/scala/org/apache/pekko/Messages.scala 7 actor-tests/src/test/scala/org/apache/pekko/PekkoExceptionSpec.scala 15 actor-tests/src/test/scala/org/apache/pekko/PekkoVersionSpec.scala 62 actor-tests/src/test/scala/org/apache/pekko/actor/ActorConfigurationVerificationSpec.scala 89 actor-tests/src/test/scala/org/apache/pekko/actor/ActorCreationPerfSpec.scala 185 actor-tests/src/test/scala/org/apache/pekko/actor/ActorLifeCycleSpec.scala 161 actor-tests/src/test/scala/org/apache/pekko/actor/ActorMailboxSpec.scala 376 actor-tests/src/test/scala/org/apache/pekko/actor/ActorPathSpec.scala 93 actor-tests/src/test/scala/org/apache/pekko/actor/ActorRefSpec.scala 366 actor-tests/src/test/scala/org/apache/pekko/actor/ActorSelectionSpec.scala 339 actor-tests/src/test/scala/org/apache/pekko/actor/ActorSystemDispatcherSpec.scala 126 actor-tests/src/test/scala/org/apache/pekko/actor/ActorSystemSpec.scala 317 actor-tests/src/test/scala/org/apache/pekko/actor/ActorTimeoutSpec.scala 26 actor-tests/src/test/scala/org/apache/pekko/actor/ActorWithBoundedStashSpec.scala 128 actor-tests/src/test/scala/org/apache/pekko/actor/ActorWithStashSpec.scala 148 actor-tests/src/test/scala/org/apache/pekko/actor/ConsistencySpec.scala 59 actor-tests/src/test/scala/org/apache/pekko/actor/CoordinatedShutdownSpec.scala 686 actor-tests/src/test/scala/org/apache/pekko/actor/DeadLetterSupressionSpec.scala 64 actor-tests/src/test/scala/org/apache/pekko/actor/DeadLetterSuspensionSpec.scala 71 actor-tests/src/test/scala/org/apache/pekko/actor/DeathWatchSpec.scala 239 actor-tests/src/test/scala/org/apache/pekko/actor/DeployerSpec.scala 60 actor-tests/src/test/scala/org/apache/pekko/actor/DynamicAccessSpec.scala 66 actor-tests/src/test/scala/org/apache/pekko/actor/ExtensionSpec.scala 117 actor-tests/src/test/scala/org/apache/pekko/actor/FSMActorSpec.scala 309 actor-tests/src/test/scala/org/apache/pekko/actor/FSMTimingSpec.scala 256 actor-tests/src/test/scala/org/apache/pekko/actor/FSMTransitionSpec.scala 144 actor-tests/src/test/scala/org/apache/pekko/actor/ForwardActorSpec.scala 39 actor-tests/src/test/scala/org/apache/pekko/actor/FunctionRefSpec.scala 90 actor-tests/src/test/scala/org/apache/pekko/actor/HotSwapSpec.scala 106 actor-tests/src/test/scala/org/apache/pekko/actor/LocalActorRefProviderSpec.scala 162 actor-tests/src/test/scala/org/apache/pekko/actor/PropsCreationSpec.scala 56 actor-tests/src/test/scala/org/apache/pekko/actor/ProviderSelectionSpec.scala 46 actor-tests/src/test/scala/org/apache/pekko/actor/ReceiveTimeoutSpec.scala 240 actor-tests/src/test/scala/org/apache/pekko/actor/RelativeActorPathSpec.scala 23 actor-tests/src/test/scala/org/apache/pekko/actor/RestartStrategySpec.scala 193 actor-tests/src/test/scala/org/apache/pekko/actor/SchedulerSpec.scala 615 actor-tests/src/test/scala/org/apache/pekko/actor/Supervisor.scala 7 actor-tests/src/test/scala/org/apache/pekko/actor/SupervisorHierarchySpec.scala 739 actor-tests/src/test/scala/org/apache/pekko/actor/SupervisorMiscSpec.scala 148 actor-tests/src/test/scala/org/apache/pekko/actor/SupervisorSpec.scala 438 actor-tests/src/test/scala/org/apache/pekko/actor/SupervisorTreeSpec.scala 33 actor-tests/src/test/scala/org/apache/pekko/actor/Ticket669Spec.scala 52 actor-tests/src/test/scala/org/apache/pekko/actor/TimerSpec.scala 276 actor-tests/src/test/scala/org/apache/pekko/actor/TypedActorSpec.scala 469 actor-tests/src/test/scala/org/apache/pekko/actor/UidClashTest.scala 72 actor-tests/src/test/scala/org/apache/pekko/actor/dispatch/ActorModelSpec.scala 535 actor-tests/src/test/scala/org/apache/pekko/actor/dispatch/BalancingDispatcherSpec.scala 72 actor-tests/src/test/scala/org/apache/pekko/actor/dispatch/DispatcherActorSpec.scala 112 actor-tests/src/test/scala/org/apache/pekko/actor/dispatch/DispatcherActorsSpec.scala 42 actor-tests/src/test/scala/org/apache/pekko/actor/dispatch/DispatchersSpec.scala 241 actor-tests/src/test/scala/org/apache/pekko/actor/dispatch/PinnedActorSpec.scala 41 actor-tests/src/test/scala/org/apache/pekko/actor/dungeon/DispatchSpec.scala 27 actor-tests/src/test/scala/org/apache/pekko/actor/routing/ListenerSpec.scala 44 actor-tests/src/test/scala/org/apache/pekko/actor/setup/ActorSystemSetupSpec.scala 51 actor-tests/src/test/scala/org/apache/pekko/config/ConfigSpec.scala 137 actor-tests/src/test/scala/org/apache/pekko/dataflow/Future2Actor.scala 45 actor-tests/src/test/scala/org/apache/pekko/dispatch/ControlAwareDispatcherSpec.scala 44 actor-tests/src/test/scala/org/apache/pekko/dispatch/DispatcherShutdownSpec.scala 30 actor-tests/src/test/scala/org/apache/pekko/dispatch/ExecutionContextSpec.scala 245 actor-tests/src/test/scala/org/apache/pekko/dispatch/ForkJoinPoolStarvationSpec.scala 50 actor-tests/src/test/scala/org/apache/pekko/dispatch/MailboxConfigSpec.scala 257 actor-tests/src/test/scala/org/apache/pekko/dispatch/PriorityDispatcherSpec.scala 62 actor-tests/src/test/scala/org/apache/pekko/dispatch/SameThreadExecutionContextSpec.scala 42 actor-tests/src/test/scala/org/apache/pekko/dispatch/StablePriorityDispatcherSpec.scala 69 actor-tests/src/test/scala/org/apache/pekko/dispatch/sysmsg/SystemMessageListSpec.scala 90 actor-tests/src/test/scala/org/apache/pekko/event/AddressTerminatedTopicBenchSpec.scala 39 actor-tests/src/test/scala/org/apache/pekko/event/EventBusSpec.scala 261 actor-tests/src/test/scala/org/apache/pekko/event/EventStreamSpec.scala 358 actor-tests/src/test/scala/org/apache/pekko/event/LoggerSpec.scala 289 actor-tests/src/test/scala/org/apache/pekko/event/LoggingReceiveSpec.scala 268 actor-tests/src/test/scala/org/apache/pekko/event/MarkerLoggingSpec.scala 28 actor-tests/src/test/scala/org/apache/pekko/event/jul/JavaLoggerSpec.scala 64 actor-tests/src/test/scala/org/apache/pekko/io/CapacityLimitSpec.scala 26 actor-tests/src/test/scala/org/apache/pekko/io/InetAddressDnsResolverSpec.scala 125 actor-tests/src/test/scala/org/apache/pekko/io/SimpleDnsCacheSpec.scala 54 actor-tests/src/test/scala/org/apache/pekko/io/TcpConnectionSpec.scala 831 actor-tests/src/test/scala/org/apache/pekko/io/TcpIntegrationSpec.scala 165 actor-tests/src/test/scala/org/apache/pekko/io/TcpIntegrationSpecSupport.scala 55 actor-tests/src/test/scala/org/apache/pekko/io/TcpListenerSpec.scala 151 actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala 125 actor-tests/src/test/scala/org/apache/pekko/io/UdpIntegrationSpec.scala 127 actor-tests/src/test/scala/org/apache/pekko/io/dns/AsyncDnsResolverIntegrationSpec.scala 169 actor-tests/src/test/scala/org/apache/pekko/io/dns/DnsSettingsSpec.scala 102 actor-tests/src/test/scala/org/apache/pekko/io/dns/DockerBindDnsService.scala 75 actor-tests/src/test/scala/org/apache/pekko/io/dns/IdGeneratorSpec.scala 16 actor-tests/src/test/scala/org/apache/pekko/io/dns/NameserverAddressParserSpec.scala 24 actor-tests/src/test/scala/org/apache/pekko/io/dns/internal/AsyncDnsManagerSpec.scala 44 actor-tests/src/test/scala/org/apache/pekko/io/dns/internal/AsyncDnsResolverSpec.scala 252 actor-tests/src/test/scala/org/apache/pekko/io/dns/internal/DnsClientSpec.scala 200 actor-tests/src/test/scala/org/apache/pekko/io/dns/internal/MessageSpec.scala 22 actor-tests/src/test/scala/org/apache/pekko/io/dns/internal/ResolvConfParserSpec.scala 46 actor-tests/src/test/scala/org/apache/pekko/io/dns/internal/TcpDnsClientSpec.scala 71 actor-tests/src/test/scala/org/apache/pekko/pattern/AskSpec.scala 216 actor-tests/src/test/scala/org/apache/pekko/pattern/BackoffOnRestartSupervisorSpec.scala 206 actor-tests/src/test/scala/org/apache/pekko/pattern/BackoffSupervisorSpec.scala 348 actor-tests/src/test/scala/org/apache/pekko/pattern/CircuitBreakerMTSpec.scala 82 actor-tests/src/test/scala/org/apache/pekko/pattern/CircuitBreakerSpec.scala 628 actor-tests/src/test/scala/org/apache/pekko/pattern/CircuitBreakerStressSpec.scala 66 actor-tests/src/test/scala/org/apache/pekko/pattern/PatternSpec.scala 53 actor-tests/src/test/scala/org/apache/pekko/pattern/PipeToSpec.scala 74 actor-tests/src/test/scala/org/apache/pekko/pattern/PromiseRefSpec.scala 52 actor-tests/src/test/scala/org/apache/pekko/pattern/RetrySpec.scala 115 actor-tests/src/test/scala/org/apache/pekko/pattern/StatusReplySpec.scala 79 actor-tests/src/test/scala/org/apache/pekko/pattern/extended/ExplicitAskSpec.scala 37 actor-tests/src/test/scala/org/apache/pekko/routing/BalancingSpec.scala 133 actor-tests/src/test/scala/org/apache/pekko/routing/BroadcastSpec.scala 66 actor-tests/src/test/scala/org/apache/pekko/routing/ConfiguredLocalRoutingSpec.scala 47 actor-tests/src/test/scala/org/apache/pekko/routing/ConsistentHashingRouterSpec.scala 92 actor-tests/src/test/scala/org/apache/pekko/routing/MetricsBasedResizerSpec.scala 257 actor-tests/src/test/scala/org/apache/pekko/routing/RandomSpec.scala 78 actor-tests/src/test/scala/org/apache/pekko/routing/ResizerSpec.scala 181 actor-tests/src/test/scala/org/apache/pekko/routing/RoundRobinSpec.scala 156 actor-tests/src/test/scala/org/apache/pekko/routing/RouteeCreationSpec.scala 41 actor-tests/src/test/scala/org/apache/pekko/routing/RoutingSpec.scala 213 actor-tests/src/test/scala/org/apache/pekko/routing/ScatterGatherFirstCompletedSpec.scala 83 actor-tests/src/test/scala/org/apache/pekko/routing/SmallestMailboxSpec.scala 48 actor-tests/src/test/scala/org/apache/pekko/routing/TailChoppingSpec.scala 97 actor-tests/src/test/scala/org/apache/pekko/serialization/AsyncSerializeSpec.scala 103 actor-tests/src/test/scala/org/apache/pekko/serialization/DisabledJavaSerializerWarningSpec.scala 46 actor-tests/src/test/scala/org/apache/pekko/serialization/NoVerification.scala 3 actor-tests/src/test/scala/org/apache/pekko/serialization/PrimitivesSerializationSpec.scala 131 actor-tests/src/test/scala/org/apache/pekko/serialization/SerializationSetupSpec.scala 161 actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala 488 actor-tests/src/test/scala/org/apache/pekko/testkit/CallingThreadDispatcherModelSpec.scala 42 actor-tests/src/test/scala/org/apache/pekko/util/AsciiStringCopySpec.scala 30 actor-tests/src/test/scala/org/apache/pekko/util/BoundedBlockingQueueSpec.scala 685 actor-tests/src/test/scala/org/apache/pekko/util/ByteIteratorSpec.scala 24 actor-tests/src/test/scala/org/apache/pekko/util/ByteStringInitializationSpec.scala 44 actor-tests/src/test/scala/org/apache/pekko/util/ByteStringSpec.scala 1276 actor-tests/src/test/scala/org/apache/pekko/util/DoubleLinkedListSpec.scala 170 actor-tests/src/test/scala/org/apache/pekko/util/DurationSpec.scala 55 actor-tests/src/test/scala/org/apache/pekko/util/FrequencyListSpec.scala 175 actor-tests/src/test/scala/org/apache/pekko/util/FrequencySketchSpec.scala 265 actor-tests/src/test/scala/org/apache/pekko/util/ImmutableIntMapSpec.scala 112 actor-tests/src/test/scala/org/apache/pekko/util/IndexSpec.scala 124 actor-tests/src/test/scala/org/apache/pekko/util/LineNumberSpecCodeForScala.scala 16 actor-tests/src/test/scala/org/apache/pekko/util/ManifestInfoSpec.scala 30 actor-tests/src/test/scala/org/apache/pekko/util/MessageBufferSpec.scala 159 actor-tests/src/test/scala/org/apache/pekko/util/PrettyDurationSpec.scala 36 actor-tests/src/test/scala/org/apache/pekko/util/RecencyListSpec.scala 87 actor-tests/src/test/scala/org/apache/pekko/util/ReflectSpec.scala 43 actor-tests/src/test/scala/org/apache/pekko/util/Scala212CompatTest.scala 37 actor-tests/src/test/scala/org/apache/pekko/util/SegmentedRecencyListSpec.scala 102 actor-tests/src/test/scala/org/apache/pekko/util/SwitchSpec.scala 80 actor-tests/src/test/scala/org/apache/pekko/util/TokenBucketSpec.scala 165 actor-tests/src/test/scala/org/apache/pekko/util/VersionSpec.scala 72 actor-tests/src/test/scala/org/apache/pekko/util/WildcardIndexSpec.scala 75 actor-tests/src/test/scala/org/apache/pekko/util/ZipfianGenerator.scala 30 actor-tests/src/test/scala/other/SerializerOutsidePekkoPackage.scala 11 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/Aggregator.java 85 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/AggregatorTest.java 193 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/BubblingSample.java 96 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/BubblingSampleTest.java 32 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/DispatchersDocTest.java 14 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/FSMDocTest.java 116 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/GracefulStopDocTest.java 165 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/InteractionPatternsAskWithStatusTest.java 165 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/InteractionPatternsTest.java 714 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/IntroTest.java 287 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/LoggingDocExamples.java 136 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/MailboxDocTest.java 38 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/OOIntroTest.java 186 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/RouterTest.java 158 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/SpawnProtocolDocTest.java 59 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/StashDocSample.java 126 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/StashDocTest.java 41 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/StyleGuideDocExamples.java 557 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/TailChopping.java 102 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/coexistence/ClassicWatchingTypedTest.java 78 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/coexistence/TypedWatchingClassicTest.java 75 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/extensions/ExtensionDocTest.java 51 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/fromclassic/ClassicSample.java 33 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/fromclassic/TypedSample.java 95 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/pubsub/PubSubExample.java 24 actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/supervision/SupervisionCompileOnlyTest.java 124 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/ActorSystemTest.java 24 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/DispatcherSelectorTest.java 6 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/ExtensionsTest.java 77 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/MailboxSelectorTest.java 6 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/SchedulerTest.java 18 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/eventstream/EventStreamTest.java 9 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/ActorCompile.java 182 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/ActorContextAskTest.java 131 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/ActorContextPipeToSelfTest.java 124 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/ActorLoggingTest.java 100 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/AdapterTest.java 331 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/BehaviorBuilderTest.java 165 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/InterceptTest.java 83 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/ReceiveBuilderTest.java 139 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/RoutersTest.java 48 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/StashBufferTest.java 43 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/javadsl/WatchTest.java 95 actor-typed-tests/src/test/java/org/apache/pekko/actor/typed/receptionist/ReceptionistApiTest.java 87 actor-typed-tests/src/test/resources/logback-doc-dev.xml 21 actor-typed-tests/src/test/resources/logback-doc-prod.xml 21 actor-typed-tests/src/test/resources/logback-doc-test.xml 18 actor-typed-tests/src/test/resources/logback-test.xml 16 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ActorContextSpec.scala 624 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ActorRefIgnoreSpec.scala 94 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ActorRefResolverSpec.scala 37 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/AskSpec.scala 174 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/BehaviorSpec.scala 563 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/DeferredSpec.scala 152 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/ExtensionsSpec.scala 226 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/InterceptSpec.scala 403 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/LocalActorRefProviderLogMessagesSpec.scala 57 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/LogMessagesSpec.scala 101 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/MailboxSelectorSpec.scala 79 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/MonitorSpec.scala 44 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/OrElseSpec.scala 165 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/PropsSpec.scala 16 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/SchedulerSpec.scala 11 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/SpawnProtocolSpec.scala 98 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/SupervisionSpec.scala 1313 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/TerminatedSpec.scala 23 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/TimerSpec.scala 330 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/TransformMessagesSpec.scala 147 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/WatchSpec.scala 306 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/coexistence/ClassicSupervisingTypedSpec.scala 136 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/coexistence/TypedSupervisingClassicSpec.scala 50 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/ConsumerControllerSpec.scala 527 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/DurableProducerControllerSpec.scala 223 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/DurableProducerQueueSpec.scala 75 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/DurableWorkPullingSpec.scala 329 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/ProducerControllerSpec.scala 265 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/ReliableDeliveryRandomSpec.scala 181 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/ReliableDeliverySpec.scala 159 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/TestConsumer.scala 117 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/TestDurableProducerQueue.scala 81 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/TestProducer.scala 62 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/TestProducerWithAsk.scala 73 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/TestProducerWorkPulling.scala 42 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/delivery/WorkPullingSpec.scala 220 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/eventstream/EventStreamSpec.scala 104 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/ActorRefSerializationSpec.scala 52 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/ActorSystemSpec.scala 171 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/adpater/PropsAdapterSpec.scala 17 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/receptionist/LocalReceptionistSpec.scala 205 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/receptionist/ServiceKeySerializationSpec.scala 27 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/routing/PoolRouterSpec.scala 38 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/routing/RoutingLogicSpec.scala 175 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/javadsl/AdaptationFailureSpec.scala 79 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/pubsub/LocalPubSubSpec.scala 106 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/receptionist/ReceptionistApiSpec.scala 53 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/ActorContextAskSpec.scala 207 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/ActorContextDelegateSpec.scala 77 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/ActorContextPipeToSelfSpec.scala 71 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/ActorLoggingSpec.scala 421 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/ActorThreadSpec.scala 211 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/AdaptationFailureSpec.scala 96 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/DispatcherSelectorSpec.scala 99 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/GracefulStopSpec.scala 47 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/LoggerOpsSpec.scala 67 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/MessageAdapterSpec.scala 254 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/OnSignalSpec.scala 63 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/ReceivePartialSpec.scala 44 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/RoutersSpec.scala 208 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/StashBufferSpec.scala 219 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/StashSpec.scala 618 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/StopSpec.scala 79 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/adapter/AdapterSpec.scala 311 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/scaladsl/adapter/GuardianStartupSpec.scala 62 cluster-metrics/src/test/resources/logback-test.xml 25 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsExtensionSpec.scala 84 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala 107 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsSettingsSpec.scala 27 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/EWMASpec.scala 81 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/MetricSpec.scala 237 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/MetricsCollectorSpec.scala 84 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/TestUtil.scala 149 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala 81 cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/protobuf/MessageSerializerSpec.scala 60 cluster-sharding-typed/src/test/java/jdocs/delivery/PointToPointDocExample.java 122 cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java 347 cluster-sharding-typed/src/test/java/jdocs/delivery/WorkPullingDocExample.java 271 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/AccountExampleDocTest.java 101 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/AccountExampleTest.java 161 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithEventHandlersInState.java 191 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithMutableState.java 200 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithNullDurableState.java 155 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithNullState.java 187 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/DurableStateStoreQueryUsageCompileOnlyTest.java 30 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlyTest.java 26 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/HelloWorldEventSourcedEntityExampleTest.java 75 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/HelloWorldPersistentEntityExample.java 118 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ReplicatedShardingCompileOnlySpec.java 70 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ShardingCompileOnlyTest.java 190 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ShardingReplyCompileOnlyTest.java 62 cluster-sharding-typed/src/test/java/org/apache/pekko/cluster/sharding/typed/ReplicatedShardingTest.java 200 cluster-sharding-typed/src/test/java/org/apache/pekko/cluster/sharding/typed/javadsl/ClusterShardingPersistenceTest.java 137 cluster-sharding-typed/src/test/java/org/apache/pekko/cluster/sharding/typed/javadsl/ClusterShardingSettingsCompileOnly.java 12 cluster-sharding-typed/src/test/java/org/apache/pekko/cluster/sharding/typed/javadsl/ShardedDaemonProcessCompileOnlyTest.java 42 cluster-sharding-typed/src/test/java/org/apache/pekko/cluster/sharding/typed/javadsl/ShardingEventSourcedEntityWithEnforcedRepliesCompileOnlyTest.java 70 cluster-sharding-typed/src/test/resources/logback-test.xml 16 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/FlightRecording.scala 31 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/JoinConfigCompatCheckerClusterShardingSpec.scala 66 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/ReplicatedShardingDirectReplicationSpec.scala 81 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/ReplicatedShardingSpec.scala 253 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/ShardingSerializerSpec.scala 39 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/DurableShardingSpec.scala 189 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala 417 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/internal/Murmur2Spec.scala 15 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala 370 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/scaladsl/ClusterShardingSpec.scala 289 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/scaladsl/ClusterShardingStateSpec.scala 43 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/scaladsl/ClusterShardingStatsSpec.scala 52 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/scaladsl/ShardedDaemonProcessSpec.scala 85 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/testkit/scaladsl/TestEntityRefSpec.scala 71 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ClusterShardingHealthCheckSpec.scala 88 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ClusterShardingInternalsSpec.scala 81 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ClusterShardingLeaseSpec.scala 125 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ClusterShardingSettingsSpec.scala 774 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala 67 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/CoordinatedShutdownShardingSpec.scala 150 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/DeprecatedLeastShardAllocationStrategySpec.scala 209 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/EntitiesSpec.scala 97 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/EntityTerminationSpec.scala 121 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/GetShardTypeNamesSpec.scala 41 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/JoinConfigCompatCheckShardingSpec.scala 55 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/LeastShardAllocationStrategyRandomizedSpec.scala 119 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/LeastShardAllocationStrategySpec.scala 257 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala 153 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ProxyShardingSpec.scala 63 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/RememberEntitiesAndStartEntitySpec.scala 83 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/RememberEntitiesBatchedUpdatesSpec.scala 92 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/RememberEntitiesFailureSpec.scala 310 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/RememberEntitiesShardIdExtractorChangeSpec.scala 119 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/RemoveInternalClusterShardingDataSpec.scala 179 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ShardRegionSpec.scala 134 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ShardWithLeaseSpec.scala 131 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ShardingQueriesSpec.scala 58 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/StartEntitySpec.scala 143 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/SupervisionSpec.scala 116 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/internal/RememberEntitiesShardStoreSpec.scala 96 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/internal/RememberEntitiesStarterSpec.scala 122 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/CompositeSpec.scala 329 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/EntityPassivationSpec.scala 115 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/HillClimbingAdmissionOptimizerSpec.scala 60 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/IdleSpec.scala 49 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/LeastFrequentlyUsedSpec.scala 269 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/LeastRecentlyUsedSpec.scala 293 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/MostRecentlyUsedSpec.scala 184 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/simulator/AccessPattern.scala 116 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/simulator/Simulator.scala 389 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/simulator/SimulatorSettings.scala 214 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/simulator/SimulatorStats.scala 107 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializerSpec.scala 102 cluster-tools/src/test/java/org/apache/pekko/cluster/client/ClusterClientTest.java 111 cluster-tools/src/test/java/org/apache/pekko/cluster/pubsub/DistributedPubSubMediatorTest.java 97 cluster-tools/src/test/java/org/apache/pekko/cluster/singleton/ClusterSingletonManagerTest.java 33 cluster-tools/src/test/java/org/apache/pekko/cluster/singleton/Consumer.java 50 cluster-tools/src/test/java/org/apache/pekko/cluster/singleton/TestSingletonMessages.java 51 cluster-tools/src/test/scala/org/apache/pekko/cluster/client/protobuf/ClusterClientMessageSerializerSpec.scala 28 cluster-tools/src/test/scala/org/apache/pekko/cluster/pubsub/DistributedPubSubMediatorDeadLettersSpec.scala 101 cluster-tools/src/test/scala/org/apache/pekko/cluster/pubsub/DistributedPubSubMediatorRouterSpec.scala 99 cluster-tools/src/test/scala/org/apache/pekko/cluster/pubsub/protobuf/DistributedPubSubMessageSerializerSpec.scala 37 cluster-tools/src/test/scala/org/apache/pekko/cluster/singleton/ClusterSingletonLeaseSpec.scala 174 cluster-tools/src/test/scala/org/apache/pekko/cluster/singleton/ClusterSingletonLeavingSpeedSpec.scala 120 cluster-tools/src/test/scala/org/apache/pekko/cluster/singleton/ClusterSingletonProxySpec.scala 76 cluster-tools/src/test/scala/org/apache/pekko/cluster/singleton/ClusterSingletonRestart2Spec.scala 113 cluster-tools/src/test/scala/org/apache/pekko/cluster/singleton/ClusterSingletonRestartSpec.scala 101 cluster-tools/src/test/scala/org/apache/pekko/cluster/singleton/protobuf/ClusterSingletonMessageSerializerSpec.scala 24 cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorDocSample.java 135 cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorDocTest.java 80 cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java 106 cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/PingSerializerExampleTest.java 69 cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/ReceptionistExample.java 153 cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/SingletonCompileOnlyTest.java 87 cluster-typed/src/test/java/org/apache/pekko/cluster/typed/ClusterApiTest.java 47 cluster-typed/src/test/resources/logback-test.xml 16 cluster-typed/src/test/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorCompileOnlyTest.scala 97 cluster-typed/src/test/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorSpec.scala 12 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/ActorRefIgnoreSerializationSpec.scala 87 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/ActorSystemSpec.scala 182 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/ClusterActorLoggingSpec.scala 43 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/ClusterApiSpec.scala 77 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/ClusterDispatcherSelectorSpec.scala 8 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/ClusterSingletonApiSpec.scala 85 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/ClusterSingletonPoisonPillSpec.scala 40 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/GroupRouterSpec.scala 147 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/RemoteContextAskSpec.scala 78 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/RemoteDeployNotAllowedSpec.scala 30 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/RemoteMessageSpec.scala 62 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/internal/PekkoClusterTypedSerializerSpec.scala 30 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/internal/delivery/ReliableDeliverySerializerSpec.scala 73 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionistSpec.scala 663 cluster-typed/src/test/scala/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionistStateSpec.scala 52 cluster/src/test/java/org/apache/pekko/cluster/ClusterJavaCompileTest.java 14 cluster/src/test/scala/org/apache/pekko/cluster/ClusterConfigSpec.scala 67 cluster/src/test/scala/org/apache/pekko/cluster/ClusterDeathWatchNotificationSpec.scala 133 cluster/src/test/scala/org/apache/pekko/cluster/ClusterDeployerSpec.scala 77 cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala 198 cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventSpec.scala 282 cluster/src/test/scala/org/apache/pekko/cluster/ClusterHeartbeatReceiverSpec.scala 15 cluster/src/test/scala/org/apache/pekko/cluster/ClusterHeartbeatSenderSpec.scala 34 cluster/src/test/scala/org/apache/pekko/cluster/ClusterHeartbeatSenderStateSpec.scala 187 cluster/src/test/scala/org/apache/pekko/cluster/ClusterLogSpec.scala 74 cluster/src/test/scala/org/apache/pekko/cluster/ClusterSpec.scala 320 cluster/src/test/scala/org/apache/pekko/cluster/ClusterTestKit.scala 111 cluster/src/test/scala/org/apache/pekko/cluster/CrossDcHeartbeatSenderSpec.scala 52 cluster/src/test/scala/org/apache/pekko/cluster/DowningProviderSpec.scala 83 cluster/src/test/scala/org/apache/pekko/cluster/FailureDetectorPuppet.scala 22 cluster/src/test/scala/org/apache/pekko/cluster/GossipSpec.scala 389 cluster/src/test/scala/org/apache/pekko/cluster/GossipTargetSelectorSpec.scala 162 cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingPerfSpec.scala 29 cluster/src/test/scala/org/apache/pekko/cluster/HeartbeatNodeRingSpec.scala 44 cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckClusterSpec.scala 79 cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerRollingUpdateSpec.scala 61 cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala 440 cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatPreDefinedChecksSpec.scala 125 cluster/src/test/scala/org/apache/pekko/cluster/MemberOrderingSpec.scala 136 cluster/src/test/scala/org/apache/pekko/cluster/MembershipStateSpec.scala 85 cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala 103 cluster/src/test/scala/org/apache/pekko/cluster/ReachabilitySpec.scala 210 cluster/src/test/scala/org/apache/pekko/cluster/ResetSystemMessageSeqNrSpec.scala 64 cluster/src/test/scala/org/apache/pekko/cluster/ShutdownAfterJoinSeedNodesSpec.scala 44 cluster/src/test/scala/org/apache/pekko/cluster/StartupWithOneThreadSpec.scala 52 cluster/src/test/scala/org/apache/pekko/cluster/TestMember.scala 26 cluster/src/test/scala/org/apache/pekko/cluster/VectorClockPerfSpec.scala 83 cluster/src/test/scala/org/apache/pekko/cluster/VectorClockSpec.scala 204 cluster/src/test/scala/org/apache/pekko/cluster/protobuf/ClusterMessageSerializerSpec.scala 194 cluster/src/test/scala/org/apache/pekko/cluster/routing/ClusterRouterSupervisorSpec.scala 38 cluster/src/test/scala/org/apache/pekko/cluster/sbr/LeaseMajoritySpec.scala 34 cluster/src/test/scala/org/apache/pekko/cluster/sbr/SplitBrainResolverSpec.scala 1362 cluster/src/test/scala/org/apache/pekko/cluster/sbr/TestAddresses.scala 55 cluster/src/test/scala/org/apache/pekko/cluster/testkit/AutoDown.scala 123 cluster/src/test/scala/org/apache/pekko/cluster/testkit/AutoDownSpec.scala 105 coordination/src/test/java/org/apache/pekko/coordination/lease/javadsl/LeaseProviderTest.java 29 coordination/src/test/scala/org/apache/pekko/coordination/lease/TestLease.scala 74 coordination/src/test/scala/org/apache/pekko/coordination/lease/TestLeaseActor.scala 89 coordination/src/test/scala/org/apache/pekko/coordination/lease/TimeoutSettingsSpec.scala 43 coordination/src/test/scala/org/apache/pekko/coordination/lease/scaladsl/LeaseProviderSpec.scala 103 discovery/src/test/java/jdoc/org/apache/pekko/discovery/CompileOnlyTest.java 20 discovery/src/test/scala/doc/org/apache/pekko/discovery/CompileOnlySpec.scala 19 discovery/src/test/scala/org/apache/pekko/discovery/DiscoveryConfigurationSpec.scala 121 discovery/src/test/scala/org/apache/pekko/discovery/LookupSpec.scala 111 discovery/src/test/scala/org/apache/pekko/discovery/aggregate/AggregateServiceDiscoverySpec.scala 99 discovery/src/test/scala/org/apache/pekko/discovery/config/ConfigServiceDiscoverySpec.scala 70 discovery/src/test/scala/org/apache/pekko/discovery/config/ConfigServicesParserSpec.scala 42 discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala 102 discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsServiceDiscoverySpec.scala 88 distributed-data/src/test/java/org/apache/pekko/cluster/ddata/JavaImplOfDeltaReplicatedData.java 27 distributed-data/src/test/java/org/apache/pekko/cluster/ddata/JavaImplOfDeltaReplicatedData2.java 33 distributed-data/src/test/java/org/apache/pekko/cluster/ddata/JavaImplOfReplicatedData.java 26 distributed-data/src/test/java/org/apache/pekko/cluster/ddata/ORMapTest.java 10 distributed-data/src/test/java/org/apache/pekko/cluster/ddata/ORMultiMapTest.java 9 distributed-data/src/test/java/org/apache/pekko/cluster/ddata/PNCounterTest.java 13 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala 51 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DeltaPropagationSelectorSpec.scala 220 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/FlagSpec.scala 38 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala 162 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GSetSpec.scala 105 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala 68 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala 90 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LocalConcurrencySpec.scala 68 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala 111 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala 562 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala 370 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala 460 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala 70 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala 154 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala 38 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ReplicatorSettingsSpec.scala 25 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala 202 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/WriteAggregatorSpec.scala 432 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatedDataSerializerSpec.scala 280 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatorMessageSerializerSpec.scala 259 osgi/src/test/resources/logback-test.xml 18 osgi/src/test/scala/org/apache/pekko/osgi/ActorSystemActivatorTest.scala 54 osgi/src/test/scala/org/apache/pekko/osgi/PojoSRTestSupport.scala 110 osgi/src/test/scala/org/apache/pekko/osgi/test/PingPong.scala 13 osgi/src/test/scala/org/apache/pekko/osgi/test/TestActivators.scala 20 persistence-query/src/test/java/org/apache/pekko/persistence/query/DummyJavaReadJournal.java 25 persistence-query/src/test/java/org/apache/pekko/persistence/query/DummyJavaReadJournalForScala.java 15 persistence-query/src/test/java/org/apache/pekko/persistence/query/DummyJavaReadJournalProvider.java 22 persistence-query/src/test/java/org/apache/pekko/persistence/query/PersistenceQueryTest.java 18 persistence-query/src/test/scala/org/apache/pekko/persistence/query/DummyReadJournal.scala 54 persistence-query/src/test/scala/org/apache/pekko/persistence/query/OffsetSpec.scala 24 persistence-query/src/test/scala/org/apache/pekko/persistence/query/PersistenceQuerySpec.scala 84 persistence-query/src/test/scala/org/apache/pekko/persistence/query/internal/QuerySerializerSpec.scala 74 persistence-query/src/test/scala/org/apache/pekko/persistence/query/journal/leveldb/AllPersistenceIdsSpec.scala 60 persistence-query/src/test/scala/org/apache/pekko/persistence/query/journal/leveldb/Cleanup.scala 17 persistence-query/src/test/scala/org/apache/pekko/persistence/query/journal/leveldb/EventsByPersistenceIdSpec.scala 170 persistence-query/src/test/scala/org/apache/pekko/persistence/query/journal/leveldb/EventsByTagSpec.scala 207 persistence-query/src/test/scala/org/apache/pekko/persistence/query/journal/leveldb/TestActor.scala 24 persistence-shared/src/test/scala/org/apache/pekko/persistence/journal/leveldb/PersistencePluginProxySpec.scala 117 persistence-shared/src/test/scala/org/apache/pekko/persistence/journal/leveldb/SharedLeveldbJournalSpec.scala 98 persistence-shared/src/test/scala/org/apache/pekko/persistence/serialization/SerializerSpec.scala 358 persistence-tck/src/test/scala/org/apache/pekko/persistence/PluginCleanup.scala 17 persistence-tck/src/test/scala/org/apache/pekko/persistence/japi/JavaJournalSpecSpec.scala 6 persistence-tck/src/test/scala/org/apache/pekko/persistence/journal/inmem/InmemJournalSpec.scala 8 persistence-tck/src/test/scala/org/apache/pekko/persistence/journal/leveldb/LeveldbJournalJavaSpec.scala 18 persistence-tck/src/test/scala/org/apache/pekko/persistence/journal/leveldb/LeveldbJournalNativeSpec.scala 18 persistence-tck/src/test/scala/org/apache/pekko/persistence/journal/leveldb/LeveldbJournalNoAtomicPersistMultipleEventsSpec.scala 19 persistence-tck/src/test/scala/org/apache/pekko/persistence/snapshot/local/LocalSnapshotStoreSpec.scala 17 persistence-testkit/src/test/resources/logback-test.xml 16 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/CommonUtils.scala 84 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/javadsl/CommonSnapshotTests.scala 317 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/javadsl/CommonTestKitTests.scala 335 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/javadsl/JavaDslUtils.scala 37 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/javadsl/SnapshotNotSerializeSpec.scala 16 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/javadsl/SnapshotSerializeSpec.scala 17 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/javadsl/TestKitNotSerializeSpec.scala 15 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/javadsl/TestKitSerializeSpec.scala 14 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/CurrentEventsBySlicesSpec.scala 53 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/CurrentEventsByTagSpec.scala 44 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/EventsByPersistenceIdSpec.scala 107 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/CommonSnapshotTests.scala 335 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/CommonTestKitTests.scala 349 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/EventSourcedBehaviorNoSnapshotTestKitSpec.scala 43 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/EventSourcedBehaviorTestKitSpec.scala 302 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/MultipleJournalsSpec.scala 89 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/PersistenceTestKitJournalCompatSpec.scala 34 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/ScalaDslUtils.scala 42 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/SnapshotNotSerializeSpec.scala 16 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/SnapshotSerializeSpec.scala 17 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/TestKitNotSerializeSpec.scala 15 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/TestKitSerializeSpec.scala 14 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/state/scaladsl/PersistenceTestKitDurableStateStoreSpec.scala 186 persistence-typed-tests/src/test/java/jdocs/org/apache/pekko/persistence/typed/MyReplicatedBehavior.java 49 persistence-typed-tests/src/test/java/jdocs/org/apache/pekko/persistence/typed/ReplicatedAuctionExampleTest.java 359 persistence-typed-tests/src/test/java/jdocs/org/apache/pekko/persistence/typed/ReplicatedBlogExample.java 233 persistence-typed-tests/src/test/java/jdocs/org/apache/pekko/persistence/typed/ReplicatedMovieExample.java 80 persistence-typed-tests/src/test/java/jdocs/org/apache/pekko/persistence/typed/ReplicatedShoppingCartExample.java 125 persistence-typed-tests/src/test/java/jdocs/org/apache/pekko/persistence/typed/ReplicatedStringSet.java 67 persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/ReplicatedEventSourcingTest.java 171 persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/javadsl/EventSourcedActorFailureTest.java 109 persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/javadsl/EventSourcedBehaviorJavaDslTest.java 660 persistence-typed-tests/src/test/resources/logback-test.xml 16 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/EventPublishingSpec.scala 63 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/EventSourcedBehaviorLoggingSpec.scala 117 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/MultiJournalReplicationSpec.scala 97 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/ReplicatedEventPublishingSpec.scala 190 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/ReplicatedEventSourcingSpec.scala 380 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/ReplicatedEventSourcingTaggingSpec.scala 93 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/ReplicationBaseSpec.scala 21 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/ReplicationIllegalAccessSpec.scala 91 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/ReplicationSnapshotSpec.scala 88 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/crdt/CounterSpec.scala 112 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/crdt/LwwSpec.scala 105 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/crdt/ORSetSpec.scala 83 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/jackson/ReplicatedEventSourcingJacksonSpec.scala 39 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorFailureSpec.scala 283 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorInterceptorSpec.scala 87 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRecoveryTimeoutSpec.scala 74 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorReplySpec.scala 82 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRetentionSpec.scala 472 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala 613 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorStashSpec.scala 569 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorTimersSpec.scala 90 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorWatchSpec.scala 172 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedEventAdapterSpec.scala 180 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedSequenceNumberSpec.scala 140 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedSnapshotAdapterSpec.scala 87 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedStashOverflowSpec.scala 65 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/LoggerSourceSpec.scala 93 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/NullEmptyStateSpec.scala 59 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/OptionalSnapshotStoreSpec.scala 63 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/PerformanceSpec.scala 137 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/PrimitiveStateSpec.scala 57 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SlowInMemorySnapshotStore.scala 40 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotMutableStateSpec.scala 88 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotRecoveryWithEmptyJournalSpec.scala 75 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorInterceptorSpec.scala 83 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorReplySpec.scala 99 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorTimersSpec.scala 92 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateRevisionSpec.scala 106 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/NullEmptyStateSpec.scala 50 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/PrimitiveStateSpec.scala 46 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/BasicPersistentBehaviorTest.java 438 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/BlogPostEntity.java 189 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/BlogPostEntityDurableState.java 152 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/DurableStatePersistentBehaviorTest.java 233 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/MovieWatchList.java 102 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/NullBlogState.java 157 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/OptionalBlogState.java 169 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/PersistentFsmToTypedMigrationCompileOnlyTest.java 183 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/StashingExample.java 123 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/WebStoreCustomerFSM.java 105 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/Auction.java 43 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/AuctionCommand.java 104 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/AuctionEntity.java 227 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/AuctionEvent.java 50 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/AuctionState.java 50 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/AuctionStatus.java 7 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/Bid.java 27 persistence-typed/src/test/java/jdocs/org/apache/pekko/persistence/typed/auction/BidResultStatus.java 10 persistence-typed/src/test/java/org/apache/pekko/persistence/typed/javadsl/LoggerSourceTest.java 126 persistence-typed/src/test/java/org/apache/pekko/persistence/typed/javadsl/NullEmptyStateTest.java 88 persistence-typed/src/test/java/org/apache/pekko/persistence/typed/javadsl/PersistentActorCompileOnlyTest.java 315 persistence-typed/src/test/java/org/apache/pekko/persistence/typed/javadsl/PrimitiveStateTest.java 78 persistence-typed/src/test/resources/logback-test.xml 16 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/ClusterSingletonPersistenceSpec.scala 65 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/ManyRecoveriesSpec.scala 72 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/PersistenceIdSpec.scala 67 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/ReplicatedEventSourcingSerializationSpec.scala 29 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/StashingWhenSnapshottingSpec.scala 92 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/delivery/EventSourcedProducerQueueSpec.scala 210 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/delivery/ReliableDeliveryWithEventSourcedProducerQueueSpec.scala 133 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/delivery/WorkPullingWithEventSourcedProducerQueueSpec.scala 212 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/internal/RecoveryPermitterSpec.scala 169 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/internal/RetentionCriteriaSpec.scala 62 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/internal/StashStateSpec.scala 58 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentActorCompileOnlyTest.scala 261 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotIsOptionalSpec.scala 80 persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/serialization/ReplicatedEventSourcingSerializerSpec.scala 39 persistence/src/test/java/org/apache/pekko/persistence/fsm/AbstractPersistentFSMTest.java 256 persistence/src/test/scala/org/apache/pekko/persistence/AtLeastOnceDeliveryCrashSpec.scala 71 persistence/src/test/scala/org/apache/pekko/persistence/AtLeastOnceDeliveryFailureSpec.scala 148 persistence/src/test/scala/org/apache/pekko/persistence/AtLeastOnceDeliverySpec.scala 353 persistence/src/test/scala/org/apache/pekko/persistence/AtomicWriteSpec.scala 30 persistence/src/test/scala/org/apache/pekko/persistence/EndToEndEventAdapterSpec.scala 208 persistence/src/test/scala/org/apache/pekko/persistence/EventAdapterSpec.scala 189 persistence/src/test/scala/org/apache/pekko/persistence/EventSourcedActorDeleteFailureSpec.scala 64 persistence/src/test/scala/org/apache/pekko/persistence/EventSourcedActorFailureSpec.scala 266 persistence/src/test/scala/org/apache/pekko/persistence/LoadPluginSpec.scala 50 persistence/src/test/scala/org/apache/pekko/persistence/ManyRecoveriesSpec.scala 60 persistence/src/test/scala/org/apache/pekko/persistence/OptimizedRecoverySpec.scala 79 persistence/src/test/scala/org/apache/pekko/persistence/OptionalSnapshotStoreSpec.scala 52 persistence/src/test/scala/org/apache/pekko/persistence/PerformanceSpec.scala 155 persistence/src/test/scala/org/apache/pekko/persistence/PersistenceSpec.scala 92 persistence/src/test/scala/org/apache/pekko/persistence/PersistentActorBoundedStashingSpec.scala 120 persistence/src/test/scala/org/apache/pekko/persistence/PersistentActorJournalProtocolSpec.scala 224 persistence/src/test/scala/org/apache/pekko/persistence/PersistentActorRecoveryTimeoutSpec.scala 96 persistence/src/test/scala/org/apache/pekko/persistence/PersistentActorSpec.scala 1557 persistence/src/test/scala/org/apache/pekko/persistence/PersistentActorStashingSpec.scala 252 persistence/src/test/scala/org/apache/pekko/persistence/RecoveryPermitterSpec.scala 140 persistence/src/test/scala/org/apache/pekko/persistence/SliceRangesSpec.scala 35 persistence/src/test/scala/org/apache/pekko/persistence/SnapshotDecodeFailureSpec.scala 55 persistence/src/test/scala/org/apache/pekko/persistence/SnapshotDirectoryFailureSpec.scala 45 persistence/src/test/scala/org/apache/pekko/persistence/SnapshotFailureRobustnessSpec.scala 211 persistence/src/test/scala/org/apache/pekko/persistence/SnapshotRecoveryLocalStoreSpec.scala 51 persistence/src/test/scala/org/apache/pekko/persistence/SnapshotRecoveryWithEmptyJournalSpec.scala 87 persistence/src/test/scala/org/apache/pekko/persistence/SnapshotSerializationSpec.scala 83 persistence/src/test/scala/org/apache/pekko/persistence/SnapshotSpec.scala 219 persistence/src/test/scala/org/apache/pekko/persistence/TimerPersistentActorSpec.scala 91 persistence/src/test/scala/org/apache/pekko/persistence/fsm/PersistentFSMSpec.scala 476 persistence/src/test/scala/org/apache/pekko/persistence/journal/InmemEventAdaptersSpec.scala 113 persistence/src/test/scala/org/apache/pekko/persistence/journal/ReplayFilterSpec.scala 217 persistence/src/test/scala/org/apache/pekko/persistence/journal/SteppingInmemJournal.scala 111 persistence/src/test/scala/org/apache/pekko/persistence/journal/chaos/ChaosJournal.scala 63 persistence/src/test/scala/org/apache/pekko/persistence/journal/inmem/InmemJournalSpec.scala 49 persistence/src/test/scala/org/apache/pekko/persistence/journal/leveldb/CompactionSegmentManagementSpec.scala 78 persistence/src/test/scala/org/apache/pekko/persistence/journal/leveldb/JournalCompactionSpec.scala 152 persistence/src/test/scala/org/apache/pekko/persistence/serialization/MessageSerializerSpec.scala 15 pki/src/test/scala/org/apache/pekko/pki/pem/DERPrivateKeyLoaderSpec.scala 38 pki/src/test/scala/org/apache/pekko/pki/pem/PEMDecoderSpec.scala 72 remote-tests/src/multi-jvm/scala/org/apache/pekko/io/DnsSpec.scala 45 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/AttemptSysMsgRedeliverySpec.scala 82 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/LookupRemoteActorSpec.scala 54 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/NewRemoteActorSpec.scala 97 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/PiercingShouldKeepQuarantineSpec.scala 59 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemoteDeliverySpec.scala 63 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemoteDeploymentDeathWatchSpec.scala 89 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemoteFeaturesSpec.scala 316 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemoteNodeDeathWatchSpec.scala 354 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemoteNodeRestartDeathWatchSpec.scala 91 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemoteQuarantinePiercingSpec.scala 90 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemoteReDeploymentSpec.scala 163 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/RemotingMultiNodeSpec.scala 19 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/TransportFailSpec.scala 114 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/BenchmarkFileReporter.scala 69 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/DirectMemorySpec.scala 69 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/FanInThrougputSpec.scala 141 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/FanOutThrougputSpec.scala 139 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/HandshakeRestartReceiverSpec.scala 106 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/LatencySpec.scala 291 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/MaxThroughputSpec.scala 414 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/PlotResult.scala 14 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/RemoteRestartedQuarantinedSpec.scala 99 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/SurviveInboundStreamRestartWithCompressionInFlightSpec.scala 109 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/SurviveNetworkPartitionSpec.scala 76 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/TestMessage.scala 55 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/TestRateReporter.scala 23 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/UdpPortActor.scala 17 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/aeron/AeronStreamConcistencySpec.scala 158 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/aeron/AeronStreamLatencySpec.scala 272 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/aeron/AeronStreamMaxThroughputSpec.scala 183 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/aeron/AeronStreamMultiNodeSpec.scala 30 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/classic/RemoteGatePiercingSpec.scala 72 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/classic/RemoteNodeRestartGateSpec.scala 94 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/classic/RemoteNodeShutdownAndComesBackSpec.scala 100 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/classic/Ticket15109Spec.scala 77 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/routing/RemoteRandomSpec.scala 83 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/routing/RemoteRoundRobinSpec.scala 155 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/routing/RemoteScatterGatherSpec.scala 92 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/sample/MultiNodeSample.scala 43 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/testconductor/TestConductorSpec.scala 78 remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/testkit/MultiNodeSpecSpec.scala 23 remote-tests/src/test/protobuf/TestMessages.proto 25 remote-tests/src/test/scala/org/apache/pekko/remote/artery/ArteryFailedToBindSpec.scala 48 remote-tests/src/test/scala/org/apache/pekko/remote/classic/RemotingFailedToBindSpec.scala 38 remote-tests/src/test/scala/org/apache/pekko/remote/testconductor/BarrierSpec.scala 535 remote-tests/src/test/scala/org/apache/pekko/remote/testconductor/ControllerSpec.scala 32 remote-tests/src/test/scala/org/apache/pekko/remote/testkit/LogRoleReplace.scala 96 remote-tests/src/test/scala/org/apache/pekko/remote/testkit/STMultiNodeSpec.scala 12 remote-tests/src/test/scala/org/scalatest/extra/QuietReporter.scala 12 remote/src/test/java/org/apache/pekko/remote/artery/RateReporter.java 48 remote/src/test/java/org/apache/pekko/remote/artery/aeron/AeronStat.java 188 remote/src/test/java/org/apache/pekko/remote/transport/ThrottlerTransportAdapterTest.java 15 remote/src/test/protobuf/ProtobufProtocol.proto 18 remote/src/test/protobuf/ProtobufProtocolV3.proto 21 remote/src/test/resources/ssl/gen-artery-nodes.example.com.sh 12 remote/src/test/resources/ssl/gen-functions.sh 81 remote/src/test/resources/ssl/genca.sh 21 remote/src/test/resources/ssl/gencerts.sh 13 remote/src/test/scala-jdk9-only/org/apache/pekko/remote/artery/jfr/JFRRemotingFlightRecorderSpec.scala 31 remote/src/test/scala/org/apache/pekko/remote/AccrualFailureDetectorSpec.scala 185 remote/src/test/scala/org/apache/pekko/remote/AckedDeliverySpec.scala 254 remote/src/test/scala/org/apache/pekko/remote/DaemonicSpec.scala 41 remote/src/test/scala/org/apache/pekko/remote/DeadlineFailureDetectorSpec.scala 79 remote/src/test/scala/org/apache/pekko/remote/EndpointRegistrySpec.scala 111 remote/src/test/scala/org/apache/pekko/remote/FailureDetectorRegistrySpec.scala 115 remote/src/test/scala/org/apache/pekko/remote/LogSourceSpec.scala 43 remote/src/test/scala/org/apache/pekko/remote/MessageLoggingSpec.scala 80 remote/src/test/scala/org/apache/pekko/remote/NetworkFailureSpec.scala 85 remote/src/test/scala/org/apache/pekko/remote/RemoteActorMailboxSpec.scala 6 remote/src/test/scala/org/apache/pekko/remote/RemoteConfigSpec.scala 117 remote/src/test/scala/org/apache/pekko/remote/RemoteConsistentHashingRouterSpec.scala 29 remote/src/test/scala/org/apache/pekko/remote/RemoteDeployerSpec.scala 48 remote/src/test/scala/org/apache/pekko/remote/RemoteFeaturesSpec.scala 132 remote/src/test/scala/org/apache/pekko/remote/RemoteRouterSpec.scala 246 remote/src/test/scala/org/apache/pekko/remote/Ticket1978CommunicationSpec.scala 172 remote/src/test/scala/org/apache/pekko/remote/Ticket1978ConfigSpec.scala 24 remote/src/test/scala/org/apache/pekko/remote/TransientSerializationErrorSpec.scala 100 remote/src/test/scala/org/apache/pekko/remote/TypedActorRemoteDeploySpec.scala 55 remote/src/test/scala/org/apache/pekko/remote/artery/ActorRefResolveCacheQuarantineSpec.scala 38 remote/src/test/scala/org/apache/pekko/remote/artery/ArteryMultiNodeSpec.scala 67 remote/src/test/scala/org/apache/pekko/remote/artery/ArterySpecSupport.scala 30 remote/src/test/scala/org/apache/pekko/remote/artery/BindCanonicalAddressSpec.scala 94 remote/src/test/scala/org/apache/pekko/remote/artery/DuplicateFlushSpec.scala 72 remote/src/test/scala/org/apache/pekko/remote/artery/DuplicateHandshakeSpec.scala 94 remote/src/test/scala/org/apache/pekko/remote/artery/EnvelopeBufferSpec.scala 189 remote/src/test/scala/org/apache/pekko/remote/artery/FlushOnShutdownSpec.scala 36 remote/src/test/scala/org/apache/pekko/remote/artery/HandshakeDenySpec.scala 29 remote/src/test/scala/org/apache/pekko/remote/artery/HandshakeFailureSpec.scala 38 remote/src/test/scala/org/apache/pekko/remote/artery/HandshakeRetrySpec.scala 31 remote/src/test/scala/org/apache/pekko/remote/artery/ImmutableLongMapSpec.scala 127 remote/src/test/scala/org/apache/pekko/remote/artery/InboundControlJunctionSpec.scala 63 remote/src/test/scala/org/apache/pekko/remote/artery/InboundHandshakeSpec.scala 86 remote/src/test/scala/org/apache/pekko/remote/artery/LargeMessagesStreamSpec.scala 101 remote/src/test/scala/org/apache/pekko/remote/artery/LateConnectSpec.scala 35 remote/src/test/scala/org/apache/pekko/remote/artery/LruBoundedCacheSpec.scala 199 remote/src/test/scala/org/apache/pekko/remote/artery/MetadataCarryingSpec.scala 126 remote/src/test/scala/org/apache/pekko/remote/artery/OutboundControlJunctionSpec.scala 52 remote/src/test/scala/org/apache/pekko/remote/artery/OutboundHandshakeSpec.scala 129 remote/src/test/scala/org/apache/pekko/remote/artery/OutboundIdleShutdownSpec.scala 156 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteActorRefProviderSpec.scala 57 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteActorSelectionSpec.scala 117 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteConnectionSpec.scala 57 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeathWatchSpec.scala 83 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeployerSpec.scala 45 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteDeploymentSpec.scala 138 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteFailureSpec.scala 52 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteInstrumentsSerializationSpec.scala 188 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteInstrumentsSpec.scala 59 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteMessageSerializationSpec.scala 102 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteRouterSpec.scala 236 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteSendConsistencySpec.scala 174 remote/src/test/scala/org/apache/pekko/remote/artery/RemoteWatcherSpec.scala 234 remote/src/test/scala/org/apache/pekko/remote/artery/RemotingFlightRecorderSpec.scala 14 remote/src/test/scala/org/apache/pekko/remote/artery/RestartCounterSpec.scala 32 remote/src/test/scala/org/apache/pekko/remote/artery/RollingEventLogSimulationSpec.scala 155 remote/src/test/scala/org/apache/pekko/remote/artery/SendQueueSpec.scala 176 remote/src/test/scala/org/apache/pekko/remote/artery/SerializationErrorSpec.scala 53 remote/src/test/scala/org/apache/pekko/remote/artery/SerializationTransportInformationSpec.scala 4 remote/src/test/scala/org/apache/pekko/remote/artery/SystemMessageAckerSpec.scala 106 remote/src/test/scala/org/apache/pekko/remote/artery/SystemMessageDeliverySpec.scala 287 remote/src/test/scala/org/apache/pekko/remote/artery/TestContext.scala 113 remote/src/test/scala/org/apache/pekko/remote/artery/TransientSerializationErrorSpec.scala 3 remote/src/test/scala/org/apache/pekko/remote/artery/UntrustedSpec.scala 138 remote/src/test/scala/org/apache/pekko/remote/artery/aeron/AeronSinkSpec.scala 64 remote/src/test/scala/org/apache/pekko/remote/artery/compress/CompressionIntegrationSpec.scala 340 remote/src/test/scala/org/apache/pekko/remote/artery/compress/CompressionTableSpec.scala 26 remote/src/test/scala/org/apache/pekko/remote/artery/compress/CompressionTestUtils.scala 9 remote/src/test/scala/org/apache/pekko/remote/artery/compress/HandshakeShouldDropCompressionTableSpec.scala 110 remote/src/test/scala/org/apache/pekko/remote/artery/compress/HeavyHittersSpec.scala 132 remote/src/test/scala/org/apache/pekko/remote/artery/compress/OutboundCompressionSpec.scala 23 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/SecureRandomFactorySpec.scala 60 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/TcpFramingSpec.scala 81 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/TlsTcpSpec.scala 209 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/ssl/CipherSuiteSupportCheck.scala 48 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/ssl/PeerSubjectVerifierSpec.scala 48 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/ssl/PemManagersProviderSpec.scala 34 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/ssl/RotatingKeysSSLEngineProviderSpec.scala 246 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/ssl/TlsResourcesSpec.scala 70 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/ssl/X509ReadersSpec.scala 20 remote/src/test/scala/org/apache/pekko/remote/classic/ActorsLeakSpec.scala 153 remote/src/test/scala/org/apache/pekko/remote/classic/RemoteDeathWatchSpec.scala 109 remote/src/test/scala/org/apache/pekko/remote/classic/RemoteDeploymentAllowListSpec.scala 101 remote/src/test/scala/org/apache/pekko/remote/classic/RemoteInitErrorSpec.scala 49 remote/src/test/scala/org/apache/pekko/remote/classic/RemoteSettingsSpec.scala 20 remote/src/test/scala/org/apache/pekko/remote/classic/RemoteWatcherSpec.scala 249 remote/src/test/scala/org/apache/pekko/remote/classic/RemotingSpec.scala 727 remote/src/test/scala/org/apache/pekko/remote/classic/UntrustedSpec.scala 167 remote/src/test/scala/org/apache/pekko/remote/classic/transport/GenericTransportSpec.scala 134 remote/src/test/scala/org/apache/pekko/remote/classic/transport/PekkoProtocolSpec.scala 336 remote/src/test/scala/org/apache/pekko/remote/classic/transport/PekkoProtocolStressTest.scala 109 remote/src/test/scala/org/apache/pekko/remote/classic/transport/SwitchableLoggedBehaviorSpec.scala 77 remote/src/test/scala/org/apache/pekko/remote/classic/transport/SystemMessageDeliveryStressTest.scala 156 remote/src/test/scala/org/apache/pekko/remote/classic/transport/TestTransportSpec.scala 102 remote/src/test/scala/org/apache/pekko/remote/classic/transport/ThrottleModeSpec.scala 76 remote/src/test/scala/org/apache/pekko/remote/classic/transport/ThrottlerTransportAdapterSpec.scala 136 remote/src/test/scala/org/apache/pekko/remote/classic/transport/netty/NettyTransportSpec.scala 145 remote/src/test/scala/org/apache/pekko/remote/serialization/AllowJavaSerializationOffSpec.scala 122 remote/src/test/scala/org/apache/pekko/remote/serialization/ArteryMessageSerializerSpec.scala 76 remote/src/test/scala/org/apache/pekko/remote/serialization/DaemonMsgCreateSerializerAllowJavaSerializationSpec.scala 155 remote/src/test/scala/org/apache/pekko/remote/serialization/MessageContainerSerializerSpec.scala 42 remote/src/test/scala/org/apache/pekko/remote/serialization/MiscMessageSerializerSpec.scala 225 remote/src/test/scala/org/apache/pekko/remote/serialization/PrimitivesSerializationSpec.scala 131 remote/src/test/scala/org/apache/pekko/remote/serialization/ProtobufSerializerSpec.scala 93 remote/src/test/scala/org/apache/pekko/remote/serialization/SerializationTransportInformationSpec.scala 117 remote/src/test/scala/org/apache/pekko/remote/serialization/SystemMessageSerializationSpec.scala 89 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/MySerializable.java 10 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/SerializationDocTest.java 62 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v1/Customer.java 16 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v1/ItemAdded.java 12 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v1/OrderAdded.java 10 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v1withv2/ItemAddedMigration.java 23 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2a/Address.java 13 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2a/Customer.java 13 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2a/CustomerMigration.java 26 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2a/ItemAdded.java 29 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2a/OrderPlaced.java 10 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2a/OrderPlacedMigration.java 17 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2b/ItemAdded.java 14 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2b/ItemAddedMigration.java 19 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2c/ItemAdded.java 12 serialization-jackson/src/test/java/jdoc/org/apache/pekko/serialization/jackson/v2c/ItemAddedMigration.java 19 serialization-jackson/src/test/java/org/apache/pekko/serialization/jackson/JavaTestEventMigrationV2.java 22 serialization-jackson/src/test/java/org/apache/pekko/serialization/jackson/JavaTestEventMigrationV2WithV3.java 42 serialization-jackson/src/test/java/org/apache/pekko/serialization/jackson/JavaTestEventMigrationV3.java 36 serialization-jackson/src/test/java/org/apache/pekko/serialization/jackson/JavaTestMessages.java 411 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/CustomAdtSerializer.scala 44 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/SerializationDocSpec.scala 337 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v1/Customer.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v1/ItemAdded.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v1/OrderAdded.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v1withv2/ItemAddedMigration.scala 16 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2a/Address.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2a/Customer.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2a/CustomerMigration.scala 24 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2a/ItemAdded.scala 9 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2a/OrderPlaced.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2a/OrderPlacedMigration.scala 9 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2b/ItemAdded.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2b/ItemAddedMigration.scala 15 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2c/ItemAdded.scala 3 serialization-jackson/src/test/scala/doc/org/apache/pekko/serialization/jackson/v2c/ItemAddedMigration.scala 15 serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/CborSerializable.scala 2 serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/JacksonSerializerSpec.scala 1034 serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/JsonSerializable.scala 2 serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/ScalaTestEventMigration.scala 65 slf4j/src/test/resources/logback-test.xml 28 slf4j/src/test/scala/org/apache/pekko/event/slf4j/Slf4jLoggerSpec.scala 197 slf4j/src/test/scala/org/apache/pekko/event/slf4j/Slf4jLoggingFilterSpec.scala 94 stream-testkit/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterSpecKit.scala 521 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/BaseTwoStreamsSetup.scala 51 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/ChainSetup.scala 37 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/ScriptedTest.scala 213 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/StreamSpec.scala 58 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/StreamTestDefaultMailbox.scala 34 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/StreamTestKitSpec.scala 153 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/TestPublisherSubscriberSpec.scala 56 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/TwoStreamsSetup.scala 27 stream-testkit/src/test/scala/org/apache/pekko/stream/testkit/Utils.scala 20 stream-tests-tck/src/test/scala-jdk9-only/org/apache/pekko/stream/tck/IterablePublisherViaJavaFlowPublisherTest.scala 16 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/ActorSystemLifecycle.scala 39 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/CancelledSinkSubscriberTest.scala 18 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/ConcatTest.scala 10 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/EmptyPublisherTest.scala 7 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FanoutPublisherTest.scala 15 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FilePublisherTest.scala 34 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FlatMapConcatDoubleSubscriberTest.scala 19 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FlatMapPrefixTest.scala 14 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FlattenTest.scala 13 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FoldSinkSubscriberTest.scala 8 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/ForeachSinkSubscriberTest.scala 11 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FusableProcessorTest.scala 15 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/FuturePublisherTest.scala 15 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/GroupByTest.scala 18 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/InputStreamSourceTest.scala 23 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/IterablePublisherTest.scala 10 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/MapTest.scala 9 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/MaybeSourceTest.scala 11 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/PekkoIdentityProcessorVerification.scala 39 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/PekkoPublisherVerification.scala 31 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/PekkoSubscriberVerification.scala 26 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/PrefixAndTailTest.scala 14 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/SingleElementSourceTest.scala 10 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/SinkholeSubscriberTest.scala 37 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/SplitWhenTest.scala 18 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/Timeouts.scala 6 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/TransformProcessorTest.scala 28 stream-tests-tck/src/test/scala/org/apache/pekko/stream/tck/VirtualPublisherTest.scala 20 stream-tests/src/test/java-jdk9-only/org/apache/pekko/stream/javadsl/JavaFlowSupportCompileTest.java 35 stream-tests/src/test/java/org/apache/pekko/stream/StreamAttributeDocTest.java 47 stream-tests/src/test/java/org/apache/pekko/stream/StreamTest.java 10 stream-tests/src/test/java/org/apache/pekko/stream/io/InputStreamSinkTest.java 34 stream-tests/src/test/java/org/apache/pekko/stream/io/OutputStreamSinkTest.java 51 stream-tests/src/test/java/org/apache/pekko/stream/io/OutputStreamSourceTest.java 44 stream-tests/src/test/java/org/apache/pekko/stream/io/SinkAsJavaSourceTest.java 29 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/AttributesTest.java 56 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/FlowLogWithMarkerTest.java 16 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/FlowTest.java 1233 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/FlowThrottleTest.java 35 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/FlowWithContextTest.java 48 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/FlowWithContextThrottleTest.java 45 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/FramingTest.java 24 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/GraphDslTest.java 176 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/JsonFramingTest.java 42 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/KillSwitchTest.java 78 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/LazyAndFutureFlowTest.java 48 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/LazyAndFutureSourcesTest.java 79 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/RetryFlowTest.java 220 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/RunnableGraphTest.java 33 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SetupTest.java 60 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SinkTest.java 140 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SourceRunWithTest.java 22 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SourceTest.java 1170 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SourceUnfoldTest.java 12 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SourceWithContextThrottleTest.java 35 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/TcpTest.java 179 stream-tests/src/test/java/org/apache/pekko/stream/stage/JavaIdentityStage.java 43 stream-tests/src/test/java/org/apache/pekko/stream/stage/StageTest.java 32 stream-tests/src/test/scala-jdk9-only/org/apache/pekko/stream/scaladsl/FlowPublisherSinkSpec.scala 26 stream-tests/src/test/scala/org/apache/pekko/stream/ActorMaterializerSpec.scala 134 stream-tests/src/test/scala/org/apache/pekko/stream/DslConsistencySpec.scala 122 stream-tests/src/test/scala/org/apache/pekko/stream/DslFactoriesConsistencySpec.scala 241 stream-tests/src/test/scala/org/apache/pekko/stream/FusingSpec.scala 122 stream-tests/src/test/scala/org/apache/pekko/stream/SourceLocationAttributeSpec.scala 13 stream-tests/src/test/scala/org/apache/pekko/stream/StreamAttributeDocSpec.scala 28 stream-tests/src/test/scala/org/apache/pekko/stream/StreamDispatcherSpec.scala 20 stream-tests/src/test/scala/org/apache/pekko/stream/SystemMaterializerSpec.scala 31 stream-tests/src/test/scala/org/apache/pekko/stream/impl/FanoutProcessorSpec.scala 79 stream-tests/src/test/scala/org/apache/pekko/stream/impl/FixedBufferSpec.scala 120 stream-tests/src/test/scala/org/apache/pekko/stream/impl/GraphStageLogicSpec.scala 337 stream-tests/src/test/scala/org/apache/pekko/stream/impl/LinearTraversalBuilderSpec.scala 710 stream-tests/src/test/scala/org/apache/pekko/stream/impl/ResizableMultiReaderRingBufferSpec.scala 181 stream-tests/src/test/scala/org/apache/pekko/stream/impl/SubInletOutletSpec.scala 169 stream-tests/src/test/scala/org/apache/pekko/stream/impl/TimeoutsSpec.scala 300 stream-tests/src/test/scala/org/apache/pekko/stream/impl/TraversalBuilderSpec.scala 338 stream-tests/src/test/scala/org/apache/pekko/stream/impl/TraversalTestUtils.scala 143 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/ActorGraphInterpreterSpec.scala 350 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/AsyncCallbackSpec.scala 229 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/ChasingEventsSpec.scala 92 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterFailureModesSpec.scala 83 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterPortsSpec.scala 976 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterSpec.scala 203 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/InterpreterSpec.scala 418 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/InterpreterStressSpec.scala 88 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/InterpreterSupervisionSpec.scala 137 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/KeepGoingStageSpec.scala 145 stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/LifecycleInterpreterSpec.scala 175 stream-tests/src/test/scala/org/apache/pekko/stream/impl/io/TLSUtilsSpec.scala 64 stream-tests/src/test/scala/org/apache/pekko/stream/io/ByteStringParserSpec.scala 125 stream-tests/src/test/scala/org/apache/pekko/stream/io/DeprecatedTlsSpec.scala 455 stream-tests/src/test/scala/org/apache/pekko/stream/io/FileSinkSpec.scala 210 stream-tests/src/test/scala/org/apache/pekko/stream/io/FileSourceSpec.scala 241 stream-tests/src/test/scala/org/apache/pekko/stream/io/InputStreamSinkSpec.scala 207 stream-tests/src/test/scala/org/apache/pekko/stream/io/InputStreamSourceSpec.scala 115 stream-tests/src/test/scala/org/apache/pekko/stream/io/OutputStreamSinkSpec.scala 119 stream-tests/src/test/scala/org/apache/pekko/stream/io/OutputStreamSourceSpec.scala 154 stream-tests/src/test/scala/org/apache/pekko/stream/io/TcpHelper.scala 147 stream-tests/src/test/scala/org/apache/pekko/stream/io/TcpSpec.scala 776 stream-tests/src/test/scala/org/apache/pekko/stream/io/TlsSpec.scala 495 stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/CodecSpecSupport.scala 62 stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/CompressionTestingTools.scala 42 stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/DeflateSpec.scala 25 stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/GzipSpec.scala 39 stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/GzipWithCustomCompressionLevelSpec.scala 31 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/ActorRefBackpressureSinkSpec.scala 214 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/ActorRefBackpressureSourceSpec.scala 118 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/ActorRefSinkSpec.scala 47 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/ActorRefSourceSpec.scala 208 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/AggregateWithBoundarySpec.scala 212 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/AttributesSpec.scala 587 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/BidiFlowSpec.scala 128 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/BoundedSourceQueueSpec.scala 162 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/CancellationStrategySpec.scala 235 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/CollectionSinkSpec.scala 51 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/CompressionSpec.scala 26 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/CoupledTerminationFlowSpec.scala 222 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FailedSourceSpec.scala 20 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowAlsoToAllSpec.scala 28 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowAppendSpec.scala 42 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowAskSpec.scala 209 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowBatchSpec.scala 88 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowBatchWeightedSpec.scala 30 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowBufferSpec.scala 179 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectSpec.scala 37 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectTypeSpec.scala 20 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCompileSpec.scala 104 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowConcatAllLazySpec.scala 81 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowConcatAllSpec.scala 174 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowConcatSpec.scala 226 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowConflateSpec.scala 217 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDelaySpec.scala 273 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDetacherSpec.scala 29 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDispatcherSpec.scala 26 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDropSpec.scala 28 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDropWhileSpec.scala 38 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDropWithinSpec.scala 42 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowExpandSpec.scala 97 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowExtrapolateSpec.scala 112 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFilterSpec.scala 79 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapPrefixSpec.scala 610 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlattenMergeSpec.scala 236 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFoldAsyncSpec.scala 273 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFoldSpec.scala 63 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowForeachSpec.scala 43 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFromFutureSpec.scala 81 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFutureFlowSpec.scala 438 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowGroupBySpec.scala 522 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowGroupedSpec.scala 30 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowGroupedWeightedSpec.scala 89 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowGroupedWithinSpec.scala 284 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowIdleInjectSpec.scala 111 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowInitialDelaySpec.scala 32 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowInterleaveAllSpec.scala 87 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowInterleaveSpec.scala 188 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowIntersperseSpec.scala 52 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowIteratorSpec.scala 160 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowJoinSpec.scala 122 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowKillSwitchSpec.scala 228 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowLimitSpec.scala 48 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowLimitWeightedSpec.scala 53 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowLogSpec.scala 141 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowLogWithMarkerSpec.scala 160 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMapAsyncSpec.scala 464 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMapAsyncUnorderedSpec.scala 310 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMapConcatSpec.scala 62 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMapErrorSpec.scala 60 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMapSpec.scala 33 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMergeAllSpec.scala 44 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMergeSpec.scala 133 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMonitorSpec.scala 64 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowOnCompleteSpec.scala 81 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowOrElseSpec.scala 121 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowPrefixAndTailSpec.scala 209 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowPrependSpec.scala 18 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowRecoverSpec.scala 60 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowRecoverWithSpec.scala 195 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowReduceSpec.scala 72 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowScanAsyncSpec.scala 242 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowScanSpec.scala 74 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowSectionSpec.scala 69 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowSlidingSpec.scala 54 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowSpec.scala 477 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowSplitAfterSpec.scala 240 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowSplitWhenSpec.scala 290 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowStatefulMapConcatSpec.scala 79 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowStatefulMapSpec.scala 245 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowSupervisionSpec.scala 45 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowTakeSpec.scala 36 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowTakeWhileSpec.scala 35 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowTakeWithinSpec.scala 48 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowThrottleSpec.scala 338 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowWatchSpec.scala 56 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowWatchTerminationSpec.scala 60 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowWireTapSpec.scala 39 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowWithContextLogSpec.scala 84 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowWithContextSpec.scala 71 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowWithContextThrottleSpec.scala 172 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipAllSpec.scala 75 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipSpec.scala 63 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipWithIndexSpec.scala 31 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipWithSpec.scala 83 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FramingSpec.scala 339 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FromMaterializationSpec.scala 245 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphBackedFlowSpec.scala 256 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphBalanceSpec.scala 315 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphBroadcastSpec.scala 254 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphConcatSpec.scala 122 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphDSLCompileSpec.scala 373 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMatValueSpec.scala 213 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMergeLatestSpec.scala 119 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMergePreferredSpec.scala 83 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMergePrioritizedNSpec.scala 131 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMergePrioritizedSpec.scala 116 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMergeSequenceSpec.scala 65 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMergeSortedSpec.scala 36 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphMergeSpec.scala 155 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphOpsIntegrationSpec.scala 193 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphPartialSpec.scala 97 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphPartitionSpec.scala 330 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphStageTimersSpec.scala 184 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipSpec.scala 177 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala 280 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphWireTapSpec.scala 48 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphZipLatestSpec.scala 189 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphZipLatestWithSpec.scala 248 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphZipNSpec.scala 170 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphZipSpec.scala 168 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphZipWithNSpec.scala 123 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphZipWithSpec.scala 165 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/HeadSinkSpec.scala 80 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/HubSpec.scala 587 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/JsonFramingSpec.scala 463 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/LastSinkSpec.scala 45 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/LazilyAsyncSpec.scala 74 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/LazyFlowSpec.scala 332 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/LazySinkSpec.scala 143 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/LazySourceSpec.scala 361 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/MaybeSourceSpec.scala 74 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/NeverSourceSpec.scala 20 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/PublisherSinkSpec.scala 37 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/QueueSinkSpec.scala 187 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/QueueSourceSpec.scala 323 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala 784 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RetryFlowSpec.scala 422 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/ReverseArrowSpec.scala 222 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RunnableGraphSpec.scala 27 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SeqSinkSpec.scala 35 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SetupSpec.scala 176 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkAsJavaStreamSpec.scala 58 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkForeachAsyncSpec.scala 196 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkForeachParallelSpec.scala 102 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkSpec.scala 270 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SourceFromPublisherSpec.scala 20 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SourceSpec.scala 350 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SourceWithContextSpec.scala 129 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/StageActorRefSpec.scala 195 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/StreamConvertersSpec.scala 299 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/StreamRefsSpec.scala 456 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SubscriberSinkSpec.scala 18 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SubscriberSourceSpec.scala 16 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SubstreamSubscriptionTimeoutSpec.scala 87 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/TakeLastSinkSpec.scala 65 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/TestConfig.scala 5 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/TickSourceSpec.scala 116 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/UnfoldResourceAsyncSourceSpec.scala 352 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/UnfoldResourceSourceSpec.scala 202 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/WithContextUsageSpec.scala 177 stream-tests/src/test/scala/org/apache/pekko/stream/snapshot/MaterializerStateSpec.scala 104 stream-typed/src/test/java/org/apache/pekko/stream/typed/javadsl/ActorSourceSinkCompileTest.java 50 stream-typed/src/test/java/org/apache/pekko/stream/typed/javadsl/CustomGuardianAndMaterializerTest.java 53 stream-typed/src/test/resources/logback-test.xml 16 stream-typed/src/test/scala/org/apache/pekko/stream/typed/scaladsl/ActorSourceSinkSpec.scala 128 stream-typed/src/test/scala/org/apache/pekko/stream/typed/scaladsl/MaterializerForTypedSpec.scala 52 stream-typed/src/test/scala/org/apache/pekko/stream/typed/scaladsl/PubSubSpec.scala 42 testkit/src/test/java/org/apache/pekko/testkit/PekkoJUnitActorSystemResource.java 43 testkit/src/test/java/org/apache/pekko/testkit/TestActorRefJavaCompile.java 16 testkit/src/test/java/org/apache/pekko/testkit/javadsl/TestKitApiTest.java 133 testkit/src/test/scala/org/apache/pekko/testkit/AbstractSpec.scala 5 testkit/src/test/scala/org/apache/pekko/testkit/Coroner.scala 193 testkit/src/test/scala/org/apache/pekko/testkit/CoronerSpec.scala 108 testkit/src/test/scala/org/apache/pekko/testkit/DefaultTimeoutSpec.scala 14 testkit/src/test/scala/org/apache/pekko/testkit/ExplicitlyTriggeredSchedulerSpec.scala 69 testkit/src/test/scala/org/apache/pekko/testkit/ImplicitSenderSpec.scala 14 testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpec.scala 95 testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala 79 testkit/src/test/scala/org/apache/pekko/testkit/TestActorRefSpec.scala 276 testkit/src/test/scala/org/apache/pekko/testkit/TestActorsSpec.scala 20 testkit/src/test/scala/org/apache/pekko/testkit/TestEventListenerSpec.scala 58 testkit/src/test/scala/org/apache/pekko/testkit/TestFSMRefSpec.scala 78 testkit/src/test/scala/org/apache/pekko/testkit/TestProbeSpec.scala 182 testkit/src/test/scala/org/apache/pekko/testkit/TestTags.scala 7 testkit/src/test/scala/org/apache/pekko/testkit/TestTimeSpec.scala 30 testkit/src/test/scala/org/apache/pekko/testkit/WithLogCapturing.scala 55 testkit/src/test/scala/org/apache/pekko/testkit/metrics/AveragingGauge.scala 16 testkit/src/test/scala/org/apache/pekko/testkit/metrics/FileDescriptorMetricSet.scala 23 testkit/src/test/scala/org/apache/pekko/testkit/metrics/HdrHistogram.scala 30 testkit/src/test/scala/org/apache/pekko/testkit/metrics/KnownOpsInTimespanTimer.scala 13 testkit/src/test/scala/org/apache/pekko/testkit/metrics/MemoryUsageSnapshotting.scala 59 testkit/src/test/scala/org/apache/pekko/testkit/metrics/MetricKeyDSL.scala 19 testkit/src/test/scala/org/apache/pekko/testkit/metrics/MetricsKit.scala 112 testkit/src/test/scala/org/apache/pekko/testkit/metrics/MetricsKitOps.scala 51 testkit/src/test/scala/org/apache/pekko/testkit/metrics/MetricsKitSpec.scala 52 testkit/src/test/scala/org/apache/pekko/testkit/metrics/reporter/PekkoConsoleReporter.scala 135