This is an automated email from the ASF dual-hosted git repository.
hepin pushed a change to branch He-Pin-patch-1
in repository https://gitbox.apache.org/repos/asf/pekko.git
from c39fed1086 Update Scala 3 version to 3.3.7-RC2
add f879bbb553 chore: Remove left org.apache.pekko.japi.Function in doc
(#2105)
add 2a04e9649e Add OSGi headers to pekko-pki (#2107)
add 273dc116d4 chore: Remove SecurityManager usage. (#2106)
add 5f87ed2ed6 feat: Add Untyped actor with stash for Java 21 (#2097)
add 2ebb98da0a Update metrics-core, metrics-jvm to 4.2.35 (#2115)
add 95820eda15 Update jackson-core to 2.20.0 (#2114)
add 39cbb3936e chore: Test if materializerPromise is already completed
first. (#2117)
add 617d1c5faa chore: Remove the deprecated annotation from recoverWith
(#2119)
add b5131ae689 feat: Add Flow/Source#onErrorResume for javadsl. (#2120)
add 28680b3548 Pin sbt-assembly version to 2.2 (#2122)
add e3c5fe222c release notes for 1.2.0 (#2082)
add 18545a6737 remove ssl-config dependency (#2127)
add 5db362f58f chore: Remove the deprecated onDownstreamFinish method in
GraphStage (#2129)
add f4979fdfb0 Update metrics-core, metrics-jvm to 4.2.36 (#2132)
add 4f3631ef76 Update netty-handler, netty-transport to 4.2.5.Final (#2133)
add 11e2121224 chore(deps): bump VirtusLab/scala-cli-setup from 1.8.5 to
1.9.0 (#2138)
add a0f807d05a chore: Drop ActorMaterializer class. (#2137)
add 70a9f092dd remove more deprecation annotations by making fields less
accessible (#2136)
add 6f2a65da4c chore: Make use of japi.function in stream api. (#2143)
add 61de190fca chore: Add doc for AsyncCallback (#2142)
add 7cf3f6193d feat: Add andThen and compose to japi function (#2147)
add 72808dc035 test ByteString lastIndexOf (#2151)
add 6e436584ac extend ByteString benchmarks (#2154)
add c708891504 chore: Use while loop (#2155)
add 9b6797f3d8 add tests for ByteStrings with non-zero startIndex (#2158)
add 47e7e23f2d chore: make toAttributes a lazy val (#2157)
add c87b3cff72 Update sbt, scripted-plugin to 1.11.6 (#2167)
add 8d9450b19e chore: Add boolean parameter name when call
registerForExecution (#2173)
add 7b96bb8385 chore: Remove ExecutorServiceFactoryProvider from
ThreadPoolConfig (#2175)
add 458ceed37e feat: Add virtualize support for thread-pool-executor
(#2169)
add 44d5b78cf2 chore(deps): bump sbt/setup-sbt from 1.1.12 to 1.1.13
(#2179)
add 91401ebca1 Add 1.2.x branch to binary compatibility checks (#2181)
add 7fb098985b chore: Remove ReentrantGuard (#2161)
add 4ef6400f6a Update netty-handler, netty-transport to 4.2.6.Final (#2184)
add 4405e736c1 Update typesafe:config to 1.4.5 (#2191)
add 38b52eab96 Update gson to 2.13.2 (#2190)
add a77b6f162c Update gson to 2.13.2 (#2190)
add e8f241dba6 Update sbt-license-report to 1.8.0 (#2189)
add 42c2b493cb chore: Remove japi.option method (#2193)
add f48ec1d425 update docs for calculateDelay (#2196)
add 0f6def662f chore: Make use of japi.funtion.* in Patterns (#2198)
add f2b677dfa0 remove scala 2.12 support (#1986)
add 4d7bc6899e chore: remove scala.compat.java8 in osgi (#2211)
add c0ffd72dec Update protobuf-java to 4.32.1 (#2216)
add 94ae86fa6f Update sbt-header to 5.11.0 (#2217)
add daf3458185 Use stdlib IntFunction to not allow throwing (#2200)
add db43bf4697 Update metrics-core, metrics-jvm to 4.2.37 (#2224)
add ee704f7e5a Update sbt-develocity to 1.4 (#2223)
add e66cda2899 remove some stray java version checks (#2227)
add 5acdace08c chore: Remove compat Future (#2212)
add 8c48393cd3 chore: Remove pekko.dispatch.ExecutionContexts.parasitic
(#2208)
add 3969ae8276 chore: Remove serialversion-remover-plugin (#2204)
add 9b5e641246 feat: Add sneakyThrow for Java (#2218)
add 04f5fcd1b7 chore: Use Scala Option Converter (#2203)
add 875840d3b8 chore: Remove pekko.util.FutureConverters (#2207)
add 9b2853c730 chore: Use scala.jdk.DurationConverters (#2205)
add 8254acc0e8 chore: Remove ccompat.JavaConverters (#2234)
add d89f3ff6ab Update scalafmt version to 3.9.10 (#2225)
add 4d89553471 chore: Use scala.jdk.CollectionConverters (#2236)
add 870d4499cc chore: sort imports (#2235)
add 5657514b39 chore: Add revision to git ignore blame (#2240)
add 4f2434b650 chore: Drop @unused annotation from pekko (#2241)
add 1feb26f89e fix: drop fiddle_code (#2237)
add 3a67477afd remove unnecessary scalafix plugin (#2243)
add d555a86f6d remove unnecessary items from license (#2246)
add 343491bcdb remove unused script (#2247)
add 57812486e1 fix: drop vavr (#2248)
add a1ade992ff feat: Add Sink#count operator. (#2244)
add 0ddb7a2ec7 chore: Make val debug final (#2251)
add ff3bed8cdc remove stray ref to java 8 in build (#2252)
add 92ca0314c0 silence compiler warnings new in scala 2.13.17 (#2255)
add 183fda795f refactor compiler options (#2253)
add 2684a7fe44 chore(deps): bump VirtusLab/scala-cli-setup from 1.9.0 to
1.9.1 (#2258)
add 34285df046 Update ByteStringSpec.scala (#2257)
add 878d219f1f fix: run AsyncDnsResolverIntegrationSpec on Apple M series
machines (#2249)
add 750bf235f1 chore: Fuse in and out handler for setupStage (#2259)
add 391b71a3d0 chore: Rewrite ClassContext with scala (#2260)
add a579679445 feat: Add Sink#source (#2250)
add a55a719c8e release notes for 1.2.1 (#2245)
add 91554a46db protect 1.3.x branch (#2264)
add 3cfe37f016 chore: Use array list for better performance in
BroadcastHub (#2262)
add c5c6a5e4ed chore(deps): bump scacap/action-surefire-report from 1.9.0
to 1.9.1 (#2266)
add aec4fafa49 Update sbt-license-report to 1.9.0 (#2267)
add e3e01889c8 feat: Support setting starting number of virtual thread.
(#2242)
add 78cfe25fe9 no need for separate Scala 2 and 3 ByteStrings (#2269)
add a02c62b1fd ByteString Indexof with from and to (#2271)
add cee1ec63df use Scala FunctionConverter (#2274)
add 295e15d144 add containsSlice tests (#2275)
add 84daa52649 set up CI for 1.3 branch (#2273)
add 4a0e67a5bd Merge branch 'main' into He-Pin-patch-1
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 12 +
.git-blame-ignore-revs | 3 +
.github/workflows/binary-compatibility-checks.yml | 3 +-
.github/workflows/build-test-prValidation.yml | 8 +-
.github/workflows/dependency-graph.yml | 4 +-
.github/workflows/generate-doc-check.yml | 2 +-
.github/workflows/headers.yml | 2 +-
.github/workflows/link-validator.yml | 2 +-
.github/workflows/nightly-1.0-builds.yml | 6 +-
.github/workflows/nightly-1.1-builds.yml | 9 +-
.github/workflows/nightly-1.2-builds.yml | 13 +-
...ghtly-1.2-builds.yml => nightly-1.3-builds.yml} | 14 +-
.github/workflows/nightly-builds-aeron.yml | 2 +-
.github/workflows/nightly-builds.yml | 10 +-
.github/workflows/publish-1.0-docs.yml | 2 +-
.github/workflows/publish-1.0-nightly.yml | 2 +-
.github/workflows/publish-1.1-docs.yml | 2 +-
.github/workflows/publish-1.1-nightly.yml | 5 +-
.github/workflows/publish-1.2-docs.yml | 14 +-
.github/workflows/publish-1.2-nightly.yml | 5 +-
...ish-1.1-nightly.yml => publish-1.3-nightly.yml} | 8 +-
.github/workflows/publish-nightly.yml | 2 +-
.github/workflows/scala-steward.yml | 2 +-
.github/workflows/scala3-build.yml | 2 +-
.github/workflows/timing-tests.yml | 4 +-
.scala-steward.conf | 3 +-
.scalafix.conf | 1 -
.scalafmt.conf | 2 +-
CONTRIBUTING.md | 28 +-
LICENSE | 14 +-
NOTICE | 12 -
.../actor/testkit/typed/CapturedLogEvent.scala | 7 +-
.../apache/pekko/actor/testkit/typed/Effect.scala | 20 +-
.../pekko/actor/testkit/typed/LoggingEvent.scala | 9 +-
.../actor/testkit/typed/TestKitSettings.scala | 8 +-
.../testkit/typed/internal/ActorSystemStub.scala | 14 +-
.../typed/internal/BehaviorTestKitImpl.scala | 5 +-
.../testkit/typed/internal/CapturingAppender.scala | 2 +-
.../typed/internal/EffectfulActorContext.scala | 10 +-
.../actor/testkit/typed/internal/LogbackUtil.scala | 7 +-
.../typed/internal/LoggingTestKitImpl.scala | 6 +-
.../typed/internal/StubbedActorContext.scala | 18 +-
.../testkit/typed/internal/TestAppender.scala | 8 +-
.../testkit/typed/internal/TestProbeImpl.scala | 36 +-
.../actor/testkit/typed/javadsl/ActorTestKit.scala | 11 +-
.../testkit/typed/javadsl/BehaviorTestKit.scala | 9 +-
.../actor/testkit/typed/javadsl/Effects.scala | 9 +-
.../typed/javadsl/JUnit5TestKitBuilder.scala | 3 +-
.../actor/testkit/typed/javadsl/LogCapturing.scala | 3 +-
.../typed/javadsl/LogCapturingExtension.scala | 11 +-
.../testkit/typed/javadsl/LoggingTestKit.scala | 4 +-
.../actor/testkit/typed/javadsl/ManualTime.scala | 10 +-
.../actor/testkit/typed/javadsl/TestInbox.scala | 2 +-
.../typed/javadsl/TestKitJUnit5Extension.scala | 3 +-
.../typed/javadsl/TestKitJunitResource.scala | 5 +-
.../actor/testkit/typed/javadsl/TestProbe.scala | 9 +-
.../testkit/typed/scaladsl/ActorTestKit.scala | 9 +-
.../testkit/typed/scaladsl/ActorTestKitBase.scala | 6 +-
.../testkit/typed/scaladsl/BehaviorTestKit.scala | 14 +-
.../testkit/typed/scaladsl/LogCapturing.scala | 5 +-
.../testkit/typed/scaladsl/LoggingTestKit.scala | 4 +-
.../actor/testkit/typed/scaladsl/ManualTime.scala | 4 +-
.../typed/scaladsl/ScalaTestWithActorTestKit.scala | 11 +-
.../testkit/typed/scaladsl/ActorTestKitSpec.scala | 11 +-
.../typed/scaladsl/BehaviorTestKitSpec.scala | 14 +-
.../typed/scaladsl/JUnit5TestKitBuilderSpec.scala | 6 +-
.../typed/scaladsl/LoggingEventFilterSpec.scala | 5 +-
.../testkit/typed/scaladsl/TestAppenderSpec.scala | 5 +-
.../testkit/typed/scaladsl/TestProbeSpec.scala | 5 +-
actor-tests/src/test/bind/etc/db.0 | 12 -
actor-tests/src/test/bind/etc/db.127 | 13 -
actor-tests/src/test/bind/etc/db.255 | 12 -
actor-tests/src/test/bind/etc/db.bar.example | 2 +-
actor-tests/src/test/bind/etc/db.empty | 14 -
actor-tests/src/test/bind/etc/db.foo.test | 3 +-
actor-tests/src/test/bind/etc/db.local | 14 -
actor-tests/src/test/bind/etc/db.root | 90 --
actor-tests/src/test/bind/etc/named.conf | 11 -
.../src/test/bind/etc/named.conf.default-zones | 30 -
actor-tests/src/test/bind/etc/named.conf.local | 8 +-
actor-tests/src/test/bind/etc/named.conf.options | 23 +-
actor-tests/src/test/bind/etc/rndc.key | 4 -
actor-tests/src/test/bind/etc/zones.rfc1918 | 2 +-
.../pekko/actor/StashJavaAPITestUntypedActors.java | 69 +
.../apache/pekko/actor/UntypedStashJavaAPI.java} | 10 +-
.../test/java/org/apache/pekko/actor/JavaAPI.java | 12 -
.../org/apache/pekko/japi/FunctionLawTest.java | 72 +
.../java/org/apache/pekko/japi/ThrowablesTest.java | 9 +
.../apache/pekko/pattern/CircuitBreakerTest.java | 10 +-
.../pekko/util/JavaConverterScala3InlineTest.java | 46 -
.../org/apache/pekko/util/TypedMultiMapSpec.scala | 1 +
.../dispatch/ForkJoinPoolVirtualThreadSpec.scala | 27 +-
...pec.scala => ThreadPoolVirtualThreadSpec.scala} | 42 +-
.../dispatch/VirtualThreadPoolDispatcherSpec.scala | 6 +-
.../org/apache/pekko/PekkoExceptionSpec.scala | 4 +-
.../actor/ActorConfigurationVerificationSpec.scala | 4 +-
.../apache/pekko/actor/ActorCreationPerfSpec.scala | 6 +-
.../apache/pekko/actor/ActorLifeCycleSpec.scala | 4 +-
.../org/apache/pekko/actor/ActorMailboxSpec.scala | 11 +-
.../apache/pekko/actor/ActorSelectionSpec.scala | 4 +-
.../pekko/actor/ActorSystemDispatcherSpec.scala | 4 +-
.../org/apache/pekko/actor/ActorSystemSpec.scala | 6 +-
.../pekko/actor/ActorWithBoundedStashSpec.scala | 15 +-
.../apache/pekko/actor/ActorWithStashSpec.scala | 6 +-
.../pekko/actor/CoordinatedShutdownSpec.scala | 25 +-
.../pekko/actor/DeadLetterSupressionSpec.scala | 2 +-
.../pekko/actor/DeadLetterSuspensionSpec.scala | 2 +-
.../org/apache/pekko/actor/DeathWatchSpec.scala | 3 +-
.../org/apache/pekko/actor/DeployerSpec.scala | 6 +-
.../org/apache/pekko/actor/ExtensionSpec.scala | 13 +-
.../org/apache/pekko/actor/FSMActorSpec.scala | 11 +-
.../org/apache/pekko/actor/FunctionRefSpec.scala | 2 +-
.../pekko/actor/LocalActorRefProviderSpec.scala | 3 +-
.../org/apache/pekko/actor/PropsCreationSpec.scala | 7 +-
.../apache/pekko/actor/ProviderSelectionSpec.scala | 4 +-
.../apache/pekko/actor/RestartStrategySpec.scala | 5 +-
.../org/apache/pekko/actor/SchedulerSpec.scala | 8 +-
.../pekko/actor/SupervisorHierarchySpec.scala | 5 +-
.../apache/pekko/actor/SupervisorMiscSpec.scala | 5 +-
.../org/apache/pekko/actor/SupervisorSpec.scala | 14 +-
.../org/apache/pekko/actor/Ticket669Spec.scala | 6 +-
.../pekko/actor/dispatch/ActorModelSpec.scala | 11 +-
.../pekko/actor/dispatch/DispatcherActorSpec.scala | 2 +-
.../pekko/actor/dispatch/DispatchersSpec.scala | 15 +-
.../pekko/actor/dispatch/PinnedActorSpec.scala | 4 +-
.../pekko/actor/setup/ActorSystemSetupSpec.scala | 6 +-
.../scala/org/apache/pekko/config/ConfigSpec.scala | 7 +-
.../pekko/dispatch/DispatcherShutdownSpec.scala | 6 +-
.../pekko/dispatch/ExecutionContextSpec.scala | 2 +-
.../dispatch/ForkJoinPoolStarvationSpec.scala | 4 +-
.../apache/pekko/dispatch/MailboxConfigSpec.scala | 14 +-
.../pekko/dispatch/PriorityDispatcherSpec.scala | 10 +-
.../dispatch/SameThreadExecutionContextSpec.scala | 19 +-
.../dispatch/StablePriorityDispatcherSpec.scala | 10 +-
.../org/apache/pekko/event/EventBusSpec.scala | 7 +-
.../org/apache/pekko/event/EventStreamSpec.scala | 4 +-
.../scala/org/apache/pekko/event/LoggerSpec.scala | 9 +-
.../apache/pekko/event/LoggingReceiveSpec.scala | 12 +-
.../org/apache/pekko/io/SimpleDnsCacheSpec.scala | 6 +-
.../org/apache/pekko/io/TcpConnectionSpec.scala | 6 +-
.../org/apache/pekko/io/TcpIntegrationSpec.scala | 4 +-
.../pekko/io/TcpIntegrationSpecSupport.scala | 4 +-
.../pekko/io/UdpConnectedIntegrationSpec.scala | 2 +-
.../org/apache/pekko/io/UdpIntegrationSpec.scala | 1 +
.../io/dns/AsyncDnsResolverIntegrationSpec.scala | 10 +-
.../org/apache/pekko/io/dns/DnsSettingsSpec.scala | 4 +-
.../apache/pekko/io/dns/DockerBindDnsService.scala | 35 +-
.../io/dns/internal/AsyncDnsResolverSpec.scala | 3 +-
.../pekko/io/dns/internal/DnsClientSpec.scala | 2 +
.../apache/pekko/io/dns/internal/MessageSpec.scala | 6 +-
.../scala/org/apache/pekko/pattern/AskSpec.scala | 2 +-
.../pattern/BackoffOnRestartSupervisorSpec.scala | 3 +-
.../pekko/pattern/BackoffSupervisorSpec.scala | 6 +-
.../apache/pekko/pattern/CircuitBreakerSpec.scala | 1 +
.../pekko/pattern/CircuitBreakerStressSpec.scala | 2 +-
.../org/apache/pekko/pattern/PatternSpec.scala | 1 +
.../scala/org/apache/pekko/pattern/RetrySpec.scala | 4 +-
.../org/apache/pekko/pattern/StatusReplySpec.scala | 4 +-
.../org/apache/pekko/routing/BalancingSpec.scala | 6 +-
.../pekko/routing/ConfiguredLocalRoutingSpec.scala | 6 +-
.../org/apache/pekko/routing/ResizerSpec.scala | 4 +-
.../org/apache/pekko/routing/RoutingSpec.scala | 4 +-
.../pekko/serialization/AsyncSerializeSpec.scala | 5 +-
.../PrimitivesSerializationSpec.scala | 4 +-
.../serialization/SerializationSetupSpec.scala | 4 +-
.../apache/pekko/serialization/SerializeSpec.scala | 9 +-
.../testkit/CallingThreadDispatcherModelSpec.scala | 4 +-
.../pekko/util/BoundedBlockingQueueSpec.scala | 14 +-
.../org/apache/pekko/util/ByteIteratorSpec.scala | 4 +-
.../util/ByteStringBuilderScala213PlusSpec.scala | 0
.../org/apache/pekko/util/ByteStringSpec.scala | 228 ++-
.../org/apache/pekko/util/FrequencyListSpec.scala | 4 +-
.../apache/pekko/util/FrequencySketchSpec.scala | 4 +-
.../scala/org/apache/pekko/util/IndexSpec.scala | 6 +-
.../org/apache/pekko/util/MessageBufferSpec.scala | 4 +-
.../org/apache/pekko/util/RecencyListSpec.scala | 4 +-
.../scala/org/apache/pekko/util/ReflectSpec.scala | 5 +-
.../org/apache/pekko/util/Scala212CompatTest.scala | 78 -
.../pekko/util/SegmentedRecencyListSpec.scala | 4 +-
.../pekko/typed/InteractionPatterns3Spec.scala | 4 +-
.../docs/org/apache/pekko/typed/IntroSpec.scala | 10 +-
.../pekko/typed/fromclassic/ClassicSample.scala | 1 -
.../pekko/actor/typed/ActorContextSpec.scala | 4 +-
.../pekko/actor/typed/ActorRefIgnoreSpec.scala | 6 +-
.../pekko/actor/typed/ActorRefResolverSpec.scala | 8 +-
.../apache/pekko/actor/typed/ActorSystemSpec.scala | 5 +-
.../org/apache/pekko/actor/typed/AskSpec.scala | 5 +-
.../apache/pekko/actor/typed/BehaviorSpec.scala | 8 +-
.../apache/pekko/actor/typed/DeferredSpec.scala | 6 +-
.../apache/pekko/actor/typed/ExtensionsSpec.scala | 7 +-
.../apache/pekko/actor/typed/InterceptSpec.scala | 4 +-
.../LocalActorRefProviderLogMessagesSpec.scala | 1 +
.../apache/pekko/actor/typed/LogMessagesSpec.scala | 7 +-
.../pekko/actor/typed/MailboxSelectorSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/MonitorSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/OrElseSpec.scala | 6 +-
.../org/apache/pekko/actor/typed/PropsSpec.scala | 4 +-
.../pekko/actor/typed/SpawnProtocolSpec.scala | 6 +-
.../apache/pekko/actor/typed/SupervisionSpec.scala | 16 +-
.../apache/pekko/actor/typed/TerminatedSpec.scala | 6 +-
.../org/apache/pekko/actor/typed/TimerSpec.scala | 4 +-
.../pekko/actor/typed/TransformMessagesSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/WatchSpec.scala | 4 +-
.../coexistence/ClassicSupervisingTypedSpec.scala | 9 +-
.../coexistence/TypedSupervisingClassicSpec.scala | 4 +-
.../typed/delivery/ConsumerControllerSpec.scala | 6 +-
.../delivery/DurableProducerControllerSpec.scala | 7 +-
.../typed/delivery/DurableProducerQueueSpec.scala | 8 +-
.../typed/delivery/DurableWorkPullingSpec.scala | 3 +-
.../typed/delivery/ProducerControllerSpec.scala | 7 +-
.../delivery/ReliableDeliveryRandomSpec.scala | 9 +-
.../typed/delivery/ReliableDeliverySpec.scala | 9 +-
.../pekko/actor/typed/delivery/TestConsumer.scala | 10 +-
.../actor/typed/delivery/TestProducerWithAsk.scala | 2 +-
.../actor/typed/delivery/WorkPullingSpec.scala | 4 +-
.../typed/eventstream/EventStreamDocSpec.scala | 1 +
.../actor/typed/eventstream/EventStreamSpec.scala | 4 +-
.../typed/internal/ActorRefSerializationSpec.scala | 7 +-
.../actor/typed/internal/ActorSystemSpec.scala | 18 +-
.../typed/internal/adpater/PropsAdapterSpec.scala | 6 +-
.../receptionist/LocalReceptionistSpec.scala | 6 +-
.../receptionist/ServiceKeySerializationSpec.scala | 4 +-
.../typed/internal/routing/PoolRouterSpec.scala | 4 +-
.../typed/internal/routing/RoutingLogicSpec.scala | 6 +-
.../typed/javadsl/AdaptationFailureSpec.scala | 4 +-
.../pekko/actor/typed/pubsub/LocalPubSubSpec.scala | 4 +-
.../actor/typed/scaladsl/ActorContextAskSpec.scala | 10 +-
.../typed/scaladsl/ActorContextDelegateSpec.scala | 1 +
.../scaladsl/ActorContextPipeToSelfSpec.scala | 7 +-
.../actor/typed/scaladsl/ActorLoggingSpec.scala | 14 +-
.../actor/typed/scaladsl/ActorThreadSpec.scala | 1 +
.../typed/scaladsl/AdaptationFailureSpec.scala | 4 +-
.../typed/scaladsl/DispatcherSelectorSpec.scala | 11 +-
.../actor/typed/scaladsl/GracefulStopSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/LoggerOpsSpec.scala | 7 +-
.../actor/typed/scaladsl/MailboxSelectorSpec.scala | 9 +-
.../actor/typed/scaladsl/MessageAdapterSpec.scala | 10 +-
.../pekko/actor/typed/scaladsl/OnSignalSpec.scala | 4 +-
.../actor/typed/scaladsl/ReceivePartialSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/RoutersSpec.scala | 6 +-
.../actor/typed/scaladsl/StashBufferSpec.scala | 6 +-
.../pekko/actor/typed/scaladsl/StashSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/StopSpec.scala | 4 +-
.../actor/typed/scaladsl/adapter/AdapterSpec.scala | 8 +-
.../scaladsl/adapter/GuardianStartupSpec.scala | 8 +-
.../remove-deprecated-methods.excludes | 1 +
.../typed/internal/receptionist/Platform.scala | 26 -
.../org/apache/pekko/actor/typed/ActorSystem.scala | 6 +-
.../org/apache/pekko/actor/typed/LogOptions.scala | 4 +-
.../scala/org/apache/pekko/actor/typed/Props.scala | 2 +-
.../pekko/actor/typed/SupervisorStrategy.scala | 14 +-
.../actor/typed/delivery/ConsumerController.scala | 16 +-
.../actor/typed/delivery/ProducerController.scala | 20 +-
.../delivery/WorkPullingProducerController.scala | 12 +-
.../actor/typed/eventstream/EventStream.scala | 1 +
.../actor/typed/internal/ActorContextImpl.scala | 22 +-
.../pekko/actor/typed/internal/ActorMdc.scala | 4 +-
.../pekko/actor/typed/internal/BehaviorImpl.scala | 6 +-
.../actor/typed/internal/ExtensionsImpl.scala | 2 +-
.../actor/typed/internal/InterceptorImpl.scala | 6 +-
.../pekko/actor/typed/internal/LoggerClass.scala | 19 +-
.../actor/typed/internal/StashBufferImpl.scala | 19 +-
.../pekko/actor/typed/internal/Supervision.scala | 14 +-
.../actor/typed/internal/TimerSchedulerImpl.scala | 25 +-
.../internal/WithMdcBehaviorInterceptor.scala | 4 +-
.../internal/adapter/ActorSystemAdapter.scala | 8 +-
.../receptionist/ReceptionistMessages.scala | 3 +-
.../typed/internal/routing/PoolRouterImpl.scala | 6 +-
.../pekko/actor/typed/javadsl/ActorContext.scala | 4 +-
.../pekko/actor/typed/javadsl/AskPattern.scala | 9 +-
.../pekko/actor/typed/javadsl/Behaviors.scala | 6 +-
.../pekko/actor/typed/javadsl/ReceiveBuilder.scala | 4 +-
.../apache/pekko/actor/typed/javadsl/Routers.scala | 4 +-
.../pekko/actor/typed/javadsl/StashBuffer.scala | 4 +-
.../actor/typed/receptionist/Receptionist.scala | 2 +-
.../pekko/actor/typed/scaladsl/ActorContext.scala | 4 +-
.../pekko/actor/typed/scaladsl/AskPattern.scala | 8 +-
.../pekko/actor/typed/scaladsl/Behaviors.scala | 3 +-
.../actor/typed/scaladsl/TimerScheduler.scala | 4 +-
.../org/apache/pekko/actor/AbstractScheduler.java | 4 +-
.../bytestring-indexOf-overload.excludes | 4 +-
.../backoff-calculation.excludes | 4 +-
.../function-converters.excludes | 5 +-
.../future-converters.excludes | 16 +-
.../java-duration-converters.excludes | 6 +
.../javaapi-functions.excludes | 1 +
.../javaapi-option.excludes | 12 +
.../option-converters.excludes | 38 -
.../remove-deprecated-methods.excludes | 13 +
.../remove-scala-2.12-support.excludes | 27 +
actor/src/main/resources/reference.conf | 43 +-
.../org/apache/pekko/compat/Future.scala | 57 -
.../org/apache/pekko/compat/PartialFunction.scala | 35 -
.../internal/SameThreadExecutionContext.scala | 39 -
.../pekko/dispatch/internal/ScalaBatchable.scala | 32 -
.../org/apache/pekko/util/ByteIterator.scala | 696 ---------
.../org/apache/pekko/util/ByteString.scala | 1454 -------------------
.../org/apache/pekko/util/FunctionConverters.scala | 562 --------
.../org/apache/pekko/util/FutureConverters.scala | 43 -
.../org/apache/pekko/util/OptionConverters.scala | 91 --
.../org/apache/pekko/util/ccompat/CompatImpl.scala | 31 -
.../pekko/util/ccompat/ccompatUsedUntil213.scala | 27 -
.../org/apache/pekko/util/ccompat/package.scala | 154 --
.../org/apache/pekko/compat/Future.scala | 59 -
.../org/apache/pekko/util/FunctionConverters.scala | 30 -
.../pekko/util/ccompat/ccompatUsedUntil213.scala | 27 -
.../org/apache/pekko/util/ccompat/package.scala | 40 -
.../org/apache/pekko/compat/PartialFunction.scala | 31 -
.../internal/SameThreadExecutionContext.scala | 29 -
.../org/apache/pekko/util/ByteIterator.scala | 5 +-
.../org/apache/pekko/util/ByteString.scala | 1502 --------------------
.../org/apache/pekko/util/FutureConverters.scala | 45 -
.../org/apache/pekko/util/OptionConverters.scala | 85 --
.../apache/pekko/util/JavaDurationConverters.scala | 35 -
.../org/apache/pekko/compat/PartialFunction.scala | 31 -
.../internal/SameThreadExecutionContext.scala | 30 -
.../org/apache/pekko/util/FutureConverters.scala | 41 -
.../apache/pekko/util/JavaDurationConverters.scala | 39 -
.../org/apache/pekko/util/OptionConverters.scala | 79 -
.../org/apache/pekko/actor/AbstractActor.scala | 60 +-
.../scala/org/apache/pekko/actor/AbstractFSM.scala | 16 +-
.../org/apache/pekko/actor/AbstractProps.scala | 2 +-
.../main/scala/org/apache/pekko/actor/Actor.scala | 13 +-
.../scala/org/apache/pekko/actor/ActorCell.scala | 3 +-
.../scala/org/apache/pekko/actor/ActorPath.scala | 5 +-
.../org/apache/pekko/actor/ActorSelection.scala | 18 +-
.../scala/org/apache/pekko/actor/ActorSystem.scala | 10 +-
.../scala/org/apache/pekko/actor/Address.scala | 4 +-
.../apache/pekko/actor/CoordinatedShutdown.scala | 19 +-
.../scala/org/apache/pekko/actor/Deployer.scala | 8 +-
.../main/scala/org/apache/pekko/actor/FSM.scala | 8 +-
.../org/apache/pekko/actor/FaultHandling.scala | 35 +-
.../apache/pekko/actor/IndirectActorProducer.scala | 3 +-
.../pekko/actor/LightArrayRevolverScheduler.scala | 3 +-
.../apache/pekko/actor/RepointableActorRef.scala | 6 +-
.../scala/org/apache/pekko/actor/Scheduler.scala | 25 +-
.../main/scala/org/apache/pekko/actor/Timers.scala | 12 +-
.../org/apache/pekko/actor/dungeon/Children.scala | 14 +-
.../apache/pekko/actor/dungeon/DeathWatch.scala | 5 +-
.../org/apache/pekko/actor/dungeon/Dispatch.scala | 3 +-
.../pekko/actor/setup/ActorSystemSetup.scala | 2 +-
.../apache/pekko/dispatch/AbstractDispatcher.scala | 77 +-
.../pekko/dispatch/BalancingDispatcher.scala | 4 +-
.../apache/pekko/dispatch/BatchingExecutor.scala | 7 +-
.../apache/pekko/dispatch/CompletionStages.scala | 9 +-
.../org/apache/pekko/dispatch/Dispatcher.scala | 5 +-
.../org/apache/pekko/dispatch/Dispatchers.scala | 8 +-
.../dispatch/ForkJoinExecutorConfigurator.scala | 34 +-
.../scala/org/apache/pekko/dispatch/Future.scala | 19 +-
.../scala/org/apache/pekko/dispatch/Mailbox.scala | 7 +-
.../org/apache/pekko/dispatch/Mailboxes.scala | 8 +-
.../apache/pekko/dispatch/PinnedDispatcher.scala | 4 +-
.../apache/pekko/dispatch/ThreadPoolBuilder.scala | 86 +-
.../pekko/dispatch/VirtualThreadSupport.scala | 65 +-
.../dispatch/VirtualizedExecutorService.scala | 4 +-
.../pekko/dispatch/affinity/AffinityPool.scala | 47 +-
.../event/ActorClassificationUnsubscriber.scala | 5 +-
.../org/apache/pekko/event/LoggerMailbox.scala | 10 +-
.../scala/org/apache/pekko/event/Logging.scala | 71 +-
actor/src/main/scala/org/apache/pekko/io/Dns.scala | 8 +-
.../src/main/scala/org/apache/pekko/io/Inet.scala | 17 +-
.../apache/pekko/io/InetAddressDnsResolver.scala | 4 +-
.../org/apache/pekko/io/SelectionHandler.scala | 4 +-
.../org/apache/pekko/io/SimpleDnsManager.scala | 2 +
actor/src/main/scala/org/apache/pekko/io/Tcp.scala | 12 +-
.../scala/org/apache/pekko/io/TcpConnection.scala | 3 +-
.../apache/pekko/io/TcpIncomingConnection.scala | 3 +-
actor/src/main/scala/org/apache/pekko/io/Udp.scala | 12 +-
.../scala/org/apache/pekko/io/UdpConnected.scala | 7 +-
.../scala/org/apache/pekko/io/UdpConnection.scala | 6 +-
.../main/scala/org/apache/pekko/io/UdpSender.scala | 2 +-
.../org/apache/pekko/io/dns/CachePolicy.scala | 8 +-
.../org/apache/pekko/io/dns/DnsProtocol.scala | 2 +-
.../apache/pekko/io/dns/DnsResourceRecords.scala | 15 +-
.../org/apache/pekko/io/dns/DnsSettings.scala | 12 +-
.../org/apache/pekko/io/dns/IdGenerator.scala | 4 +-
.../pekko/io/dns/internal/AsyncDnsManager.scala | 4 +-
.../pekko/io/dns/internal/AsyncDnsResolver.scala | 4 +-
.../apache/pekko/io/dns/internal/DnsClient.scala | 4 +-
.../apache/pekko/io/dns/internal/DnsMessage.scala | 3 +-
.../pekko/io/dns/internal/ResolvConfParser.scala | 4 +-
.../pekko/io/dns/internal/TcpDnsClient.scala | 1 +
.../main/scala/org/apache/pekko/japi/JavaAPI.scala | 5 -
.../scala/org/apache/pekko/japi/Throwables.scala | 11 +
.../org/apache/pekko/japi/function/Function.scala | 40 +-
.../org/apache/pekko/pattern/AskSupport.scala | 16 +-
.../org/apache/pekko/pattern/BackoffOptions.scala | 10 +-
.../org/apache/pekko/pattern/CircuitBreaker.scala | 18 +-
.../pekko/pattern/CircuitBreakersRegistry.scala | 4 +-
.../pekko/pattern/FutureTimeoutSupport.scala | 2 +-
.../apache/pekko/pattern/GracefulStopSupport.scala | 4 +-
.../scala/org/apache/pekko/pattern/Patterns.scala | 55 +-
.../org/apache/pekko/pattern/PipeToSupport.scala | 4 +-
.../org/apache/pekko/pattern/RetrySupport.scala | 4 +-
.../org/apache/pekko/pattern/StatusReply.scala | 5 +-
.../apache/pekko/pattern/extended/package.scala | 2 +-
.../pattern/internal/CircuitBreakerTelemetry.scala | 3 +-
.../scala/org/apache/pekko/routing/Balancing.scala | 8 +-
.../scala/org/apache/pekko/routing/Broadcast.scala | 6 +-
.../org/apache/pekko/routing/ConsistentHash.scala | 2 +-
.../apache/pekko/routing/ConsistentHashing.scala | 4 +-
.../org/apache/pekko/routing/MurmurHash.scala | 3 -
.../routing/OptimalSizeExploringResizer.scala | 11 +-
.../scala/org/apache/pekko/routing/Random.scala | 6 +-
.../scala/org/apache/pekko/routing/Resizer.scala | 4 +-
.../org/apache/pekko/routing/RoundRobin.scala | 6 +-
.../org/apache/pekko/routing/RoutedActorCell.scala | 2 -
.../scala/org/apache/pekko/routing/Router.scala | 2 +-
.../org/apache/pekko/routing/RouterConfig.scala | 12 +-
.../routing/ScatterGatherFirstCompleted.scala | 14 +-
.../org/apache/pekko/routing/SmallestMailbox.scala | 6 +-
.../org/apache/pekko/routing/TailChopping.scala | 10 +-
.../pekko/serialization/AsyncSerializer.scala | 2 +-
.../apache/pekko/serialization/Serialization.scala | 8 +-
.../pekko/serialization/SerializationSetup.scala | 2 +-
.../org/apache/pekko/util/ByteString.scala | 104 +-
.../scala/org/apache/pekko/util/ConstantFun.scala | 4 +-
.../org/apache/pekko/util/DoubleLinkedList.scala | 4 +-
.../apache/pekko/util/FlightRecorderLoader.scala | 4 +-
.../org/apache/pekko/util/FrequencyList.scala | 4 +-
.../org/apache/pekko/util/FrequencySketch.scala | 6 +-
.../main/scala/org/apache/pekko/util/Helpers.scala | 2 +
.../main/scala/org/apache/pekko/util/Index.scala | 3 +-
.../scala/org/apache/pekko/util/LineNumbers.scala | 22 +-
.../scala/org/apache/pekko/util/LockUtil.scala | 10 -
.../scala/org/apache/pekko/util/ManifestInfo.scala | 3 +-
.../scala/org/apache/pekko/util/RecencyList.scala | 4 +-
.../apache/pekko/util/SegmentedRecencyList.scala | 4 +-
.../org/apache/pekko/util/SubclassifiedIndex.scala | 3 -
.../main/scala/org/apache/pekko/util/Timeout.scala | 4 +-
.../main/scala/org/apache/pekko/util/Unused.scala | 37 -
.../main/scala/org/apache/pekko/BenchRunner.scala | 2 +-
.../org/apache/pekko/actor/ActorBenchmark.scala | 3 +-
.../actor/AffinityPoolComparativeBenchmark.scala | 3 +-
.../actor/AffinityPoolIdleCPULevelBenchmark.scala | 3 +-
.../AffinityPoolRequestResponseBenchmark.scala | 3 +-
.../pekko/actor/ForkJoinActorBenchmark.scala | 3 +-
.../org/apache/pekko/actor/JCToolsMailbox.scala | 3 +-
.../apache/pekko/actor/ManyToOneArrayMailbox.scala | 3 +-
.../pekko/actor/StashCreationBenchmark.scala | 3 +-
.../org/apache/pekko/actor/TellOnlyBenchmark.scala | 5 +-
.../pekko/actor/typed/TypedActorBenchmark.scala | 3 +-
.../actor/typed/TypedForkJoinActorBenchmark.scala | 3 +-
.../typed/delivery/ReliableDeliveryBenchmark.scala | 3 +-
.../ddata/ORSetSerializationBenchmark.scala | 3 +-
.../pekko/dispatch/CachingConfigBenchmark.scala | 3 +-
.../apache/pekko/dispatch/NodeQueueBenchmark.scala | 3 +-
.../apache/pekko/io/dns/IdGeneratorBanchmark.scala | 6 +-
.../persistence/LevelDbBatchingBenchmark.scala | 6 +-
.../pekko/remote/artery/CodecBenchmark.scala | 5 +-
.../pekko/remote/artery/SendQueueBenchmark.scala | 3 +-
.../SerializationFormatCacheBenchmark.scala | 23 +-
.../jackson/JacksonSerializationBench.scala | 5 +-
.../org/apache/pekko/stream/AskBenchmark.scala | 3 +-
.../pekko/stream/BroadcastHubBenchmark.scala | 94 ++
.../org/apache/pekko/stream/CollectBenchmark.scala | 17 +-
.../pekko/stream/FlatMapConcatBenchmark.scala | 3 +-
.../org/apache/pekko/stream/FlowMapBenchmark.scala | 3 +-
.../org/apache/pekko/stream/FramingBenchmark.scala | 5 +-
.../apache/pekko/stream/FusedGraphsBenchmark.scala | 3 +-
.../apache/pekko/stream/InterpreterBenchmark.scala | 2 +-
.../pekko/stream/LazyFutureSourceBenchmark.scala | 3 +-
.../apache/pekko/stream/MapAsyncBenchmark.scala | 3 +-
.../pekko/stream/PartitionHubBenchmark.scala | 3 +-
.../apache/pekko/stream/SourceRefBenchmark.scala | 3 +-
.../pekko/stream/ZipWithIndexBenchmark.scala | 4 +-
.../apache/pekko/util/ArrayCopyOf_Benchmark.scala | 4 +-
.../pekko/util/ByteString_indexOf_Benchmark.scala | 10 +-
.../util/ByteString_lastIndexOf_Benchmark.scala | 49 +
.../pekko/util/FastFrequencySketchBenchmark.scala | 4 +-
.../pekko/util/FrequencySketchBenchmark.scala | 4 +-
.../scala/org/apache/pekko/util/StackBench.scala | 41 -
build.sbt | 20 +-
.../cluster/metrics/ClusterMetricsCollector.scala | 5 +-
.../cluster/metrics/ClusterMetricsExtension.scala | 4 +-
.../cluster/metrics/ClusterMetricsRouting.scala | 6 +-
.../cluster/metrics/ClusterMetricsSettings.scala | 4 +-
.../cluster/metrics/ClusterMetricsStrategy.scala | 4 +-
.../org/apache/pekko/cluster/metrics/Metric.scala | 5 +-
.../metrics/protobuf/MessageSerializer.scala | 6 +-
.../metrics/ClusterMetricsExtensionSpec.scala | 4 +-
.../metrics/ClusterMetricsRoutingSpec.scala | 11 +-
.../metrics/ClusterMetricsRoutingSpec.scala | 6 +-
.../metrics/ClusterMetricsSettingsSpec.scala | 4 +-
.../apache/pekko/cluster/metrics/EWMASpec.scala | 3 +-
.../apache/pekko/cluster/metrics/MetricSpec.scala | 10 +-
.../cluster/metrics/MetricsCollectorSpec.scala | 3 +-
.../apache/pekko/cluster/metrics/TestUtil.scala | 3 +-
.../cluster/metrics/WeightedRouteesSpec.scala | 4 +-
.../metrics/protobuf/NumberInputStreamSpec.scala | 1 +
.../sharding/typed/ClusterShardingQuery.scala | 4 +-
.../sharding/typed/ClusterShardingSettings.scala | 32 +-
.../sharding/typed/ReplicatedEntityProvider.scala | 14 +-
.../typed/ReplicatedShardingExtension.scala | 3 +-
.../typed/ShardedDaemonProcessSettings.scala | 10 +-
.../sharding/typed/ShardingMessageExtractor.scala | 5 +-
.../delivery/ShardingConsumerController.scala | 4 +-
.../delivery/ShardingProducerController.scala | 24 +-
.../typed/internal/ClusterShardingImpl.scala | 15 +-
.../JoinConfigCompatCheckerClusterSharding.scala | 4 +-
.../internal/ReplicatedShardingExtensionImpl.scala | 18 +-
.../typed/internal/ShardedDaemonProcessImpl.scala | 5 +-
.../typed/internal/ShardingSerializer.scala | 4 +-
.../typed/internal/testkit/TestEntityRefImpl.scala | 9 +-
.../sharding/typed/javadsl/ClusterSharding.scala | 5 +-
.../typed/javadsl/ShardedDaemonProcess.scala | 2 +-
.../sharding/typed/scaladsl/ClusterSharding.scala | 1 +
.../ClusterShardingRememberEntitiesPerfSpec.scala | 10 +-
.../ClusterShardingPreparingForShutdownSpec.scala | 7 +-
.../sharding/typed/ClusterShardingStatsSpec.scala | 7 +-
.../typed/MultiDcClusterShardingSpec.scala | 7 +-
.../sharding/typed/ReplicatedShardingSpec.scala | 8 +-
.../sharding/typed/ShardedDaemonProcessSpec.scala | 7 +-
.../typed/delivery/DeliveryThroughputSpec.scala | 4 +-
...oinConfigCompatCheckerClusterShardingSpec.scala | 9 +-
.../ReplicatedShardingDirectReplicationSpec.scala | 5 +-
.../sharding/typed/ReplicatedShardingSpec.scala | 19 +-
.../sharding/typed/ShardingSerializerSpec.scala | 7 +-
.../typed/delivery/DurableShardingSpec.scala | 8 +-
.../delivery/ReliableDeliveryShardingSpec.scala | 7 +-
.../sharding/typed/internal/Murmur2Spec.scala | 4 +-
.../scaladsl/ClusterShardingPersistenceSpec.scala | 7 +-
.../typed/scaladsl/ClusterShardingSpec.scala | 9 +-
.../typed/scaladsl/ClusterShardingStateSpec.scala | 4 +-
.../typed/scaladsl/ClusterShardingStatsSpec.scala | 4 +-
.../typed/scaladsl/ShardedDaemonProcessSpec.scala | 7 +-
.../typed/testkit/scaladsl/TestEntityRefSpec.scala | 4 +-
.../pekko/cluster/sharding/ClusterSharding.scala | 2 +-
.../sharding/ClusterShardingHealthCheck.scala | 17 +-
.../cluster/sharding/ClusterShardingSettings.scala | 17 +-
.../sharding/JoinConfigCompatCheckSharding.scala | 4 +-
.../RemoveInternalClusterShardingData.scala | 4 +-
.../org/apache/pekko/cluster/sharding/Shard.scala | 17 +-
.../pekko/cluster/sharding/ShardCoordinator.scala | 19 +-
.../pekko/cluster/sharding/ShardRegion.scala | 18 +-
.../external/ExternalShardAllocationStrategy.scala | 4 +-
.../cluster/sharding/external/ShardLocations.scala | 3 +-
.../ExternalShardAllocationClientImpl.scala | 8 +-
.../AbstractLeastShardAllocationStrategy.scala | 8 +-
.../internal/DDataRememberEntitiesShardStore.scala | 4 +-
.../internal/EntityPassivationStrategy.scala | 8 +-
...ntSourcedRememberEntitiesCoordinatorStore.scala | 8 +-
.../internal/LeastShardAllocationStrategy.scala | 1 +
.../sharding/internal/RememberEntityStarter.scala | 6 +-
.../cluster/sharding/internal/jfr/Events.scala | 3 +-
.../ClusterShardingMessageSerializer.scala | 10 +-
.../pekko/cluster/sbr/GremlinController.scala | 3 +-
.../RandomizedBrainResolverIntegrationSpec.scala | 9 +-
.../sbr/SplitBrainResolverIntegrationSpec.scala | 11 +-
.../ClusterShardCoordinatorDowning2Spec.scala | 5 +-
.../ClusterShardCoordinatorDowningSpec.scala | 5 +-
.../sharding/ClusterShardingFailureSpec.scala | 2 -
.../sharding/ClusterShardingGetStateSpec.scala | 4 +-
.../sharding/ClusterShardingGetStatsSpec.scala | 1 +
...ClusterShardingGracefulShutdownOldestSpec.scala | 4 +-
.../ClusterShardingGracefulShutdownSpec.scala | 7 +-
.../sharding/ClusterShardingLeavingSpec.scala | 2 -
.../sharding/ClusterShardingMinMembersSpec.scala | 2 -
.../sharding/ClusterShardingQueriesSpec.scala | 6 +-
...rShardingRememberEntitiesNewExtractorSpec.scala | 4 +-
.../ClusterShardingRememberEntitiesSpec.scala | 8 +-
.../ClusterShardingRolePartitioningSpec.scala | 4 +-
.../cluster/sharding/ClusterShardingSpec.scala | 7 +-
.../sharding/ExternalShardAllocationSpec.scala | 6 +-
.../sharding/MultiDcClusterShardingSpec.scala | 6 +-
.../sharding/MultiNodeClusterShardingConfig.scala | 4 +-
.../sharding/MultiNodeClusterShardingSpec.scala | 8 +-
.../RollingUpdateShardAllocationSpec.scala | 6 +-
.../sharding/ClusterShardingHealthCheckSpec.scala | 6 +-
.../sharding/ClusterShardingInternalsSpec.scala | 2 +-
.../sharding/ClusterShardingLeaseSpec.scala | 6 +-
.../sharding/ClusterShardingSettingsSpec.scala | 6 +-
.../sharding/ConcurrentStartupShardingSpec.scala | 3 +-
.../sharding/CoordinatedShutdownShardingSpec.scala | 2 -
...eprecatedLeastShardAllocationStrategySpec.scala | 4 +-
.../pekko/cluster/sharding/EntitiesSpec.scala | 1 +
.../cluster/sharding/EntityTerminationSpec.scala | 7 +-
.../JoinConfigCompatCheckShardingSpec.scala | 6 +-
...eastShardAllocationStrategyRandomizedSpec.scala | 4 +-
.../LeastShardAllocationStrategySpec.scala | 4 +-
.../sharding/PersistentShardingMigrationSpec.scala | 9 +-
.../RememberEntitiesAndStartEntitySpec.scala | 9 +-
.../RememberEntitiesBatchedUpdatesSpec.scala | 4 +-
.../sharding/RememberEntitiesFailureSpec.scala | 14 +-
...ememberEntitiesShardIdExtractorChangeSpec.scala | 9 +-
.../RemoveInternalClusterShardingDataSpec.scala | 2 +-
.../pekko/cluster/sharding/ShardRegionSpec.scala | 8 +-
.../cluster/sharding/ShardWithLeaseSpec.scala | 12 +-
.../pekko/cluster/sharding/StartEntitySpec.scala | 6 +-
.../pekko/cluster/sharding/SupervisionSpec.scala | 6 +-
.../internal/RememberEntitiesShardStoreSpec.scala | 6 +-
.../internal/RememberEntitiesStarterSpec.scala | 5 +-
.../sharding/passivation/CompositeSpec.scala | 5 +-
.../passivation/EntityPassivationSpec.scala | 10 +-
.../HillClimbingAdmissionOptimizerSpec.scala | 1 +
.../cluster/sharding/passivation/IdleSpec.scala | 4 +-
.../passivation/LeastFrequentlyUsedSpec.scala | 5 +-
.../passivation/LeastRecentlyUsedSpec.scala | 5 +-
.../passivation/MostRecentlyUsedSpec.scala | 5 +-
.../passivation/simulator/AccessPattern.scala | 4 +-
.../sharding/passivation/simulator/Simulator.scala | 15 +-
.../passivation/simulator/SimulatorSettings.scala | 10 +-
.../passivation/simulator/SimulatorStats.scala | 4 +-
.../ClusterShardingMessageSerializerSpec.scala | 1 +
.../pekko/cluster/client/ClusterClient.scala | 8 +-
.../protobuf/ClusterClientMessageSerializer.scala | 2 +-
.../cluster/pubsub/DistributedPubSubMediator.scala | 6 +-
.../DistributedPubSubMessageSerializer.scala | 6 +-
.../singleton/ClusterSingletonManager.scala | 10 +-
.../cluster/singleton/ClusterSingletonProxy.scala | 4 +-
.../cluster/client/ClusterClientHandoverSpec.scala | 6 +-
.../pekko/cluster/client/ClusterClientSpec.scala | 7 +-
.../cluster/client/ClusterClientStopSpec.scala | 6 +-
.../pubsub/DistributedPubSubMediatorSpec.scala | 4 +-
.../pubsub/DistributedPubSubRestartSpec.scala | 4 +-
.../ClusterSingletonManagerChaosSpec.scala | 4 +-
.../ClusterSingletonManagerDownedSpec.scala | 6 +-
.../ClusterSingletonManagerLeaseSpec.scala | 4 +-
.../ClusterSingletonManagerLeave2Spec.scala | 4 +-
.../ClusterSingletonManagerLeaveSpec.scala | 4 +-
...rSingletonManagerPreparingForShutdownSpec.scala | 5 +-
.../singleton/ClusterSingletonManagerSpec.scala | 4 +-
.../ClusterSingletonManagerStartupSpec.scala | 4 +-
.../singleton/MultiDcSingletonManagerSpec.scala | 4 +-
.../DistributedPubSubMediatorRouterSpec.scala | 7 +-
.../singleton/ClusterSingletonLeaseSpec.scala | 4 +-
.../ClusterSingletonLeavingSpeedSpec.scala | 6 +-
.../singleton/ClusterSingletonProxySpec.scala | 11 +-
.../singleton/ClusterSingletonRestart2Spec.scala | 6 +-
.../singleton/ClusterSingletonRestartSpec.scala | 6 +-
.../receptionist/ClusterReceptionistProtocol.scala | 27 -
.../ddata/typed/internal/ReplicatorBehavior.scala | 8 +-
.../ddata/typed/javadsl/DistributedData.scala | 5 +-
.../cluster/ddata/typed/javadsl/Replicator.scala | 15 +-
.../typed/javadsl/ReplicatorMessageAdapter.scala | 7 +-
.../ddata/typed/javadsl/ReplicatorSettings.scala | 4 +-
.../ddata/typed/scaladsl/DistributedData.scala | 8 +-
.../ddata/typed/scaladsl/ReplicatorSettings.scala | 4 +-
.../pekko/cluster/typed/ClusterSingleton.scala | 13 +-
.../typed/internal/AdaptedClusterImpl.scala | 2 +-
.../delivery/ReliableDeliverySerializer.scala | 8 +-
.../ClusterReceptionistConfigCompatChecker.scala | 4 +-
.../receptionist/ClusterReceptionistSettings.scala | 4 +-
.../cluster/typed/ChunkLargeMessageSpec.scala | 3 +-
.../typed/MultiDcClusterSingletonSpec.scala | 4 +-
.../cluster/typed/MultiNodeTypedClusterSpec.scala | 12 +-
.../apache/pekko/cluster/typed/PubSubSpec.scala | 4 +-
.../ClusterReceptionistUnreachabilitySpec.scala | 4 +-
.../ddata/typed/scaladsl/ReplicatorSpec.scala | 4 +-
.../typed/ActorRefIgnoreSerializationSpec.scala | 13 +-
.../pekko/cluster/typed/ActorSystemSpec.scala | 17 +-
.../cluster/typed/ClusterActorLoggingSpec.scala | 9 +-
.../pekko/cluster/typed/ClusterApiSpec.scala | 7 +-
.../typed/ClusterDispatcherSelectorSpec.scala | 4 +-
.../cluster/typed/ClusterSingletonApiSpec.scala | 7 +-
.../typed/ClusterSingletonPoisonPillSpec.scala | 4 +-
.../pekko/cluster/typed/GroupRouterSpec.scala | 6 +-
.../pekko/cluster/typed/RemoteContextAskSpec.scala | 7 +-
.../cluster/typed/RemoteDeployNotAllowedSpec.scala | 7 +-
.../pekko/cluster/typed/RemoteMessageSpec.scala | 4 +-
.../internal/PekkoClusterTypedSerializerSpec.scala | 4 +-
.../delivery/ReliableDeliverySerializerSpec.scala | 4 +-
.../receptionist/ClusterReceptionistSpec.scala | 10 +-
.../ClusterReceptionistStateSpec.scala | 6 +-
.../scala/org/apache/pekko/cluster/Cluster.scala | 6 +-
.../pekko/cluster/ClusterActorRefProvider.scala | 5 +-
.../org/apache/pekko/cluster/ClusterDaemon.scala | 4 +-
.../org/apache/pekko/cluster/ClusterEvent.scala | 4 +-
.../apache/pekko/cluster/ClusterHeartbeat.scala | 2 -
.../pekko/cluster/ClusterRemoteWatcher.scala | 1 +
.../org/apache/pekko/cluster/ClusterSettings.scala | 14 +-
.../org/apache/pekko/cluster/ConfigUtil.scala | 8 +-
.../pekko/cluster/CrossDcClusterHeartbeat.scala | 2 -
.../scala/org/apache/pekko/cluster/Gossip.scala | 1 +
.../cluster/JoinConfigCompatCheckCluster.scala | 4 +-
.../pekko/cluster/JoinConfigCompatChecker.scala | 8 +-
.../scala/org/apache/pekko/cluster/Member.scala | 5 +-
.../org/apache/pekko/cluster/MembershipState.scala | 2 -
.../org/apache/pekko/cluster/Reachability.scala | 2 -
.../org/apache/pekko/cluster/SeedNodeProcess.scala | 5 +-
.../protobuf/ClusterMessageSerializer.scala | 9 +-
.../cluster/routing/ClusterRouterConfig.scala | 9 +-
.../apache/pekko/cluster/sbr/DowningStrategy.scala | 1 +
.../pekko/cluster/sbr/SplitBrainResolver.scala | 2 +-
.../cluster/sbr/SplitBrainResolverSettings.scala | 4 +-
.../ClusterAccrualFailureDetectorSpec.scala | 4 +-
.../pekko/cluster/ClusterDeathWatchSpec.scala | 7 +-
.../apache/pekko/cluster/ClusterShutdownSpec.scala | 7 +-
.../ClusterWatcherNoClusterWatcheeSpec.scala | 7 +-
.../org/apache/pekko/cluster/ConvergenceSpec.scala | 4 +-
.../DeterministicOldestWhenJoiningSpec.scala | 4 +-
...henOtherHasQuarantinedThisActorSystemSpec.scala | 2 +
.../pekko/cluster/InitialHeartbeatSpec.scala | 4 +-
.../pekko/cluster/InitialMembersOfNewDcSpec.scala | 4 +-
.../apache/pekko/cluster/JoinInProgressSpec.scala | 4 +-
.../apache/pekko/cluster/JoinSeedNodeSpec.scala | 4 +-
.../pekko/cluster/LargeMessageClusterSpec.scala | 7 +-
.../cluster/LeaderDowningAllOtherNodesSpec.scala | 4 +-
.../LeaderDowningNodeThatIsUnreachableSpec.scala | 4 +-
.../apache/pekko/cluster/LeaderLeavingSpec.scala | 4 +-
.../scala/org/apache/pekko/cluster/MBeanSpec.scala | 8 +-
.../apache/pekko/cluster/MemberWeaklyUpSpec.scala | 4 +-
.../pekko/cluster/MinMembersBeforeUpSpec.scala | 6 +-
.../apache/pekko/cluster/MultiDcClusterSpec.scala | 4 +-
.../cluster/MultiDcHeartbeatTakingOverSpec.scala | 6 +-
.../apache/pekko/cluster/MultiDcJoin2Spec.scala | 4 +-
.../org/apache/pekko/cluster/MultiDcJoinSpec.scala | 4 +-
.../apache/pekko/cluster/MultiDcLastNodeSpec.scala | 4 +-
.../pekko/cluster/MultiDcSplitBrainSpec.scala | 4 +-
.../pekko/cluster/MultiDcSunnyWeatherSpec.scala | 4 +-
.../pekko/cluster/MultiNodeClusterSpec.scala | 13 +-
.../org/apache/pekko/cluster/NodeChurnSpec.scala | 4 +-
.../cluster/NodeDowningAndBeingRemovedSpec.scala | 4 +-
.../apache/pekko/cluster/NodeMembershipSpec.scala | 2 -
.../apache/pekko/cluster/QuickRestartSpec.scala | 4 +-
.../cluster/RemoteFeaturesWithClusterSpec.scala | 7 +-
.../pekko/cluster/RestartFirstSeedNodeSpec.scala | 6 +-
.../apache/pekko/cluster/RestartNode2Spec.scala | 6 +-
.../apache/pekko/cluster/RestartNode3Spec.scala | 6 +-
.../org/apache/pekko/cluster/RestartNodeSpec.scala | 6 +-
.../pekko/cluster/SharedMediaDriverSupport.scala | 3 +-
.../pekko/cluster/SingletonClusterSpec.scala | 4 +-
.../pekko/cluster/SplitBrainQuarantineSpec.scala | 5 +-
.../org/apache/pekko/cluster/SplitBrainSpec.scala | 4 +-
.../org/apache/pekko/cluster/StreamRefSpec.scala | 8 +-
.../org/apache/pekko/cluster/StressSpec.scala | 13 +-
.../apache/pekko/cluster/SunnyWeatherSpec.scala | 4 +-
.../cluster/SurviveNetworkInstabilitySpec.scala | 6 +-
.../org/apache/pekko/cluster/TransitionSpec.scala | 3 +-
.../cluster/UnreachableNodeJoinsAgainSpec.scala | 6 +-
.../ClusterConsistentHashingRouterSpec.scala | 4 +-
.../cluster/routing/ClusterRoundRobinSpec.scala | 4 +-
.../pekko/cluster/routing/UseRoleIgnoredSpec.scala | 4 +-
.../sbr/DownAllIndirectlyConnected5NodeSpec.scala | 4 +-
.../cluster/sbr/DownAllUnstable5NodeSpec.scala | 4 +-
.../cluster/sbr/IndirectlyConnected3NodeSpec.scala | 4 +-
.../cluster/sbr/IndirectlyConnected5NodeSpec.scala | 4 +-
.../pekko/cluster/sbr/LeaseMajority5NodeSpec.scala | 8 +-
.../apache/pekko/cluster/ClusterConfigSpec.scala | 6 +-
.../ClusterDeathWatchNotificationSpec.scala | 6 +-
.../apache/pekko/cluster/ClusterDeployerSpec.scala | 4 +-
.../cluster/ClusterDomainEventPublisherSpec.scala | 6 +-
.../pekko/cluster/ClusterDomainEventSpec.scala | 6 +-
.../cluster/ClusterHeartbeatSenderStateSpec.scala | 6 +-
.../org/apache/pekko/cluster/ClusterLogSpec.scala | 4 +-
.../org/apache/pekko/cluster/ClusterSpec.scala | 8 +-
.../org/apache/pekko/cluster/ClusterTestKit.scala | 4 +-
.../org/apache/pekko/cluster/ConfigUtilSpec.scala | 4 +-
.../pekko/cluster/CrossDcHeartbeatSenderSpec.scala | 2 +-
.../apache/pekko/cluster/DowningProviderSpec.scala | 17 +-
.../pekko/cluster/FailureDetectorPuppet.scala | 8 +-
.../org/apache/pekko/cluster/GossipSpec.scala | 6 +-
.../pekko/cluster/GossipTargetSelectorSpec.scala | 6 +-
.../pekko/cluster/HeartbeatNodeRingPerfSpec.scala | 4 +-
.../pekko/cluster/HeartbeatNodeRingSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckClusterSpec.scala | 6 +-
.../JoinConfigCompatCheckerRollingUpdateSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckerSpec.scala | 4 +-
.../JoinConfigCompatPreDefinedChecksSpec.scala | 3 +-
.../apache/pekko/cluster/MemberOrderingSpec.scala | 6 +-
.../apache/pekko/cluster/MembershipStateSpec.scala | 6 +-
.../pekko/cluster/MixedProtocolClusterSpec.scala | 4 +-
.../pekko/cluster/ReachabilityPerfSpec.scala | 5 +-
.../apache/pekko/cluster/ReachabilitySpec.scala | 4 +-
.../pekko/cluster/StartupWithOneThreadSpec.scala | 2 +-
.../protobuf/ClusterMessageSerializerSpec.scala | 7 +-
.../pekko/cluster/sbr/LeaseMajoritySpec.scala | 4 +-
.../pekko/cluster/sbr/SplitBrainResolverSpec.scala | 11 +-
.../coordination/lease/LeaseUsageSettings.scala | 4 +-
.../pekko/coordination/lease/TimeoutSettings.scala | 21 +-
.../coordination/lease/internal/LeaseAdapter.scala | 4 +-
.../pekko/coordination/lease/TestLease.scala | 6 +-
.../coordination/lease/TimeoutSettingsSpec.scala | 3 +-
.../lease/scaladsl/LeaseProviderSpec.scala | 4 +-
.../apache/pekko/discovery/ServiceDiscovery.scala | 6 +-
.../aggregate/AggregateServiceDiscovery.scala | 6 +-
.../discovery/config/ConfigServiceDiscovery.scala | 6 +-
.../discovery/DiscoveryConfigurationSpec.scala | 9 +-
.../aggregate/AggregateServiceDiscoverySpec.scala | 17 +-
.../config/ConfigServiceDiscoverySpec.scala | 12 +-
.../config/ConfigServicesParserSpec.scala | 9 +-
.../pekko/discovery/dns/DnsDiscoverySpec.scala | 4 +-
.../discovery/dns/DnsServiceDiscoverySpec.scala | 8 +-
.../org/apache/pekko/cluster/ddata/GSet.scala | 2 +-
.../org/apache/pekko/cluster/ddata/GSet.scala | 2 +-
.../cluster/ddata/DeltaPropagationSelector.scala | 2 -
.../apache/pekko/cluster/ddata/DurableStore.scala | 7 +-
.../org/apache/pekko/cluster/ddata/LWWMap.scala | 2 +-
.../org/apache/pekko/cluster/ddata/ORMap.scala | 2 +-
.../apache/pekko/cluster/ddata/ORMultiMap.scala | 4 +-
.../org/apache/pekko/cluster/ddata/ORSet.scala | 7 +-
.../apache/pekko/cluster/ddata/PNCounterMap.scala | 2 +-
.../apache/pekko/cluster/ddata/PruningState.scala | 5 +-
.../pekko/cluster/ddata/ReplicatedData.scala | 3 +-
.../apache/pekko/cluster/ddata/Replicator.scala | 37 +-
.../ddata/protobuf/ReplicatedDataSerializer.scala | 8 +-
.../protobuf/ReplicatorMessageSerializer.scala | 6 +-
.../ddata/protobuf/SerializationSupport.scala | 6 +-
.../pekko/cluster/ddata/DurableDataSpec.scala | 7 +-
.../pekko/cluster/ddata/DurablePruningSpec.scala | 6 +-
.../cluster/ddata/JepsenInspiredInsertSpec.scala | 4 +-
.../pekko/cluster/ddata/PerformanceSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorChaosSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorDeltaSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorGossipSpec.scala | 4 +-
.../cluster/ddata/ReplicatorMapDeltaSpec.scala | 4 +-
.../cluster/ddata/ReplicatorORSetDeltaSpec.scala | 4 +-
.../cluster/ddata/ReplicatorPruningSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorSpec.scala | 4 +-
.../pekko/cluster/ddata/STMultiNodeSpec.scala | 4 +-
.../pekko/cluster/ddata/DataEnvelopeSpec.scala | 6 +-
.../ddata/DeltaPropagationSelectorSpec.scala | 5 +-
.../org/apache/pekko/cluster/ddata/FlagSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/GCounterSpec.scala | 6 +-
.../org/apache/pekko/cluster/ddata/GSetSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/LWWMapSpec.scala | 6 +-
.../pekko/cluster/ddata/LWWRegisterSpec.scala | 6 +-
.../pekko/cluster/ddata/LocalConcurrencySpec.scala | 11 +-
.../apache/pekko/cluster/ddata/LotsOfDataBot.scala | 4 +-
.../org/apache/pekko/cluster/ddata/ORMapSpec.scala | 6 +-
.../pekko/cluster/ddata/ORMultiMapSpec.scala | 6 +-
.../org/apache/pekko/cluster/ddata/ORSetSpec.scala | 6 +-
.../pekko/cluster/ddata/PNCounterMapSpec.scala | 6 +-
.../apache/pekko/cluster/ddata/PNCounterSpec.scala | 6 +-
.../pekko/cluster/ddata/PruningStateSpec.scala | 6 +-
.../cluster/ddata/ReplicatorSettingsSpec.scala | 5 +-
.../pekko/cluster/ddata/VersionVectorSpec.scala | 8 +-
.../protobuf/ReplicatedDataSerializerSpec.scala | 11 +-
.../protobuf/ReplicatorMessageSerializerSpec.scala | 16 +-
docs/src/main/paradox/actors.md | 5 +-
docs/src/main/paradox/general/configuration.md | 2 +-
docs/src/main/paradox/persistence.md | 4 +-
.../src/main/paradox/release-notes/releases-1.2.md | 105 +-
.../main/paradox/stream/operators/ActorFlow/ask.md | 2 +-
.../stream/operators/ActorFlow/askWithContext.md | 2 +-
.../stream/operators/ActorFlow/askWithStatus.md | 4 +-
.../operators/ActorFlow/askWithStatusAndContext.md | 2 +-
.../stream/operators/ActorSource/actorRef.md | 2 +-
.../main/paradox/stream/operators/Sink/count.md | 39 +
.../stream/operators/Sink/fromMaterializer.md | 2 +-
.../main/paradox/stream/operators/Sink/source.md | 29 +
.../Source-or-Flow/aggregateWithBoundary.md | 4 +-
.../stream/operators/Source-or-Flow/delayWith.md | 4 +-
.../operators/Source-or-Flow/fromMaterializer.md | 4 +-
.../operators/Source-or-Flow/onErrorComplete.md | 4 +-
.../operators/Source-or-Flow/onErrorResume.md | 34 +
.../stream/operators/Source-or-Flow/recover.md | 4 +-
.../stream/operators/Source-or-Flow/recoverWith.md | 4 +-
.../operators/Source-or-Flow/recoverWithRetries.md | 4 +-
docs/src/main/paradox/stream/operators/index.md | 6 +
docs/src/main/paradox/stream/stream-dynamic.md | 2 +-
docs/src/main/paradox/stream/stream-error.md | 8 +-
docs/src/main/paradox/stream/stream-quickstart.md | 2 +-
docs/src/main/paradox/typed/actors.md | 2 +-
.../src/main/paradox/typed/interaction-patterns.md | 2 +-
docs/src/main/paradox/typed/style-guide.md | 3 +-
docs/src/test/java/jdocs/future/FutureDocTest.java | 19 +
.../jdocs/stream/operators/SinkDocExamples.java | 9 +
docs/src/test/scala/docs/actor/ActorDocSpec.scala | 6 -
.../docs/actor/io/dns/DnsCompileOnlyDocSpec.scala | 13 +-
.../scala/docs/ddata/DistributedDataDocSpec.scala | 2 +-
.../ddata/protobuf/TwoPhaseSetSerializer.scala | 2 +-
docs/src/test/scala/docs/io/EchoServer.scala | 8 +-
.../test/scala/docs/io/ScalaUdpMulticastSpec.scala | 2 +-
.../query/PersistenceQueryDocSpec.scala | 2 +-
.../test/scala/docs/routing/RouterDocSpec.scala | 2 +-
.../stream/TwitterStreamQuickstartDocSpec.scala | 11 +-
legal/pekko-actor-jar-license.txt | 14 +-
legal/pekko-actor-jar-notice.txt | 13 -
.../pekko/remote/testconductor/Conductor.scala | 5 +-
.../pekko/remote/testconductor/DataTypes.scala | 6 +-
.../pekko/remote/testconductor/Extension.scala | 4 +-
.../apache/pekko/remote/testconductor/Player.scala | 8 +-
.../remote/testconductor/RemoteConnection.scala | 8 +-
.../pekko/remote/testkit/MultiNodeSpec.scala | 13 +-
.../apache/pekko/osgi/ActorSystemActivator.scala | 10 +-
.../pekko/osgi/BundleDelegatingClassLoader.scala | 3 +-
.../apache/pekko/osgi/OsgiActorSystemFactory.scala | 8 +-
.../pekko/osgi/ActorSystemActivatorTest.scala | 5 +-
.../org/apache/pekko/osgi/PojoSRTestSupport.scala | 4 +-
.../pekko/persistence/query/EventEnvelope.scala | 3 +-
.../apache/pekko/persistence/query/Offset.scala | 2 +-
.../pekko/persistence/query/PersistenceQuery.scala | 8 +-
.../query/internal/QuerySerializer.scala | 2 +
.../query/javadsl/DurableStateStoreQuery.scala | 2 +-
.../persistence/query/journal/leveldb/Buffer.scala | 3 +-
.../leveldb/EventsByPersistenceIdStage.scala | 1 +
.../query/journal/leveldb/EventsByTagStage.scala | 1 +
.../leveldb/LeveldbReadJournalProvider.scala | 3 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 4 +-
.../query/scaladsl/DurableStateStoreQuery.scala | 2 +-
.../persistence/query/typed/EventEnvelope.scala | 4 +-
.../pekko/persistence/query/DummyReadJournal.scala | 18 +-
.../persistence/query/PersistenceQuerySpec.scala | 9 +-
.../journal/leveldb/AllPersistenceIdsSpec.scala | 6 +-
.../leveldb/EventsByPersistenceIdSpec.scala | 6 +-
.../query/journal/leveldb/EventsByTagSpec.scala | 6 +-
.../leveldb/PersistencePluginProxySpec.scala | 4 +-
.../journal/leveldb/SharedLeveldbJournalSpec.scala | 4 +-
.../persistence/serialization/SerializerSpec.scala | 3 +-
.../org/apache/pekko/persistence/PluginSpec.scala | 9 +-
.../apache/pekko/persistence/TestSerializer.scala | 4 +-
.../japi/journal/JavaJournalPerfSpec.scala | 6 +-
.../persistence/japi/journal/JavaJournalSpec.scala | 4 +-
.../japi/snapshot/JavaSnapshotStoreSpec.scala | 4 +-
.../persistence/journal/JournalPerfSpec.scala | 6 +-
.../pekko/persistence/journal/JournalSpec.scala | 8 +-
.../pekko/persistence/scalatest/MayVerb.scala | 1 +
.../persistence/scalatest/OptionalTests.scala | 4 +-
.../persistence/snapshot/SnapshotStoreSpec.scala | 6 +-
.../apache/pekko/persistence/PluginCleanup.scala | 1 +
.../persistence/japi/JavaJournalSpecSpec.scala | 5 +-
.../snapshot/local/LocalSnapshotStoreSpec.scala | 4 +-
.../pekko/persistence/testkit/EventStorage.scala | 6 +-
.../testkit/PersistenceTestKitPlugin.scala | 23 +-
.../persistence/testkit/ProcessingPolicy.scala | 4 +-
.../persistence/testkit/SnapshotStorage.scala | 4 +-
.../internal/EventSourcedBehaviorTestKitImpl.scala | 1 +
.../testkit/internal/InMemStorageExtension.scala | 2 +-
.../SnapshotStorageEmulatorExtension.scala | 2 +-
.../testkit/internal/TestKitStorage.scala | 4 +-
.../javadsl/EventSourcedBehaviorTestKit.scala | 11 +-
.../testkit/javadsl/PersistenceInit.scala | 7 +-
.../testkit/javadsl/PersistenceTestKit.scala | 13 +-
.../testkit/javadsl/SnapshotTestKit.scala | 13 +-
.../PersistenceTestKitReadJournalProvider.scala | 1 +
.../query/internal/EventsBySliceStage.scala | 8 +-
.../testkit/query/internal/EventsByTagStage.scala | 6 +-
.../javadsl/PersistenceTestKitReadJournal.scala | 2 +-
.../scaladsl/PersistenceTestKitReadJournal.scala | 29 +-
.../scaladsl/EventSourcedBehaviorTestKit.scala | 6 +-
.../testkit/scaladsl/PersistenceTestKit.scala | 4 +-
...rsistenceTestKitDurableStateStoreProvider.scala | 4 +-
.../PersistenceTestKitDurableStateStore.scala | 10 +-
.../PersistenceTestKitDurableStateStore.scala | 4 +-
.../pekko/persistence/testkit/CommonUtils.scala | 9 +-
.../testkit/javadsl/CommonSnapshotTests.scala | 5 +-
.../testkit/javadsl/CommonTestKitTests.scala | 5 +-
.../testkit/query/CurrentEventsBySlicesSpec.scala | 4 +-
.../testkit/query/CurrentEventsByTagSpec.scala | 1 +
.../testkit/query/EventsByPersistenceIdSpec.scala | 6 +-
.../testkit/query/EventsBySliceSpec.scala | 10 +-
.../testkit/query/EventsByTagSpec.scala | 10 +-
.../testkit/scaladsl/CommonSnapshotTests.scala | 4 +-
.../testkit/scaladsl/CommonTestKitTests.scala | 4 +-
...EventSourcedBehaviorNoSnapshotTestKitSpec.scala | 4 +-
.../scaladsl/EventSourcedBehaviorTestKitSpec.scala | 4 +-
.../testkit/scaladsl/MultipleJournalsSpec.scala | 4 +-
.../testkit/scaladsl/RuntimeJournalsSpec.scala | 4 +-
.../PersistenceTestKitDurableStateStoreSpec.scala | 3 +-
.../persistence/typed/EventPublishingSpec.scala | 1 +
.../typed/EventSourcedBehaviorLoggingSpec.scala | 7 +-
.../typed/MultiJournalReplicationSpec.scala | 8 +-
.../typed/ReplicatedEventPublishingSpec.scala | 3 +-
.../typed/ReplicatedEventSourcingSpec.scala | 1 +
.../typed/ReplicatedEventSourcingTaggingSpec.scala | 5 +-
.../persistence/typed/ReplicationBaseSpec.scala | 1 +
.../typed/ReplicationIllegalAccessSpec.scala | 1 +
.../typed/ReplicationSnapshotSpec.scala | 3 +-
.../pekko/persistence/typed/crdt/CounterSpec.scala | 2 +-
.../pekko/persistence/typed/crdt/LwwSpec.scala | 10 +-
.../pekko/persistence/typed/crdt/ORSetSpec.scala | 9 +-
.../ReplicatedEventSourcingJacksonSpec.scala | 4 +-
.../scaladsl/EventSourcedBehaviorFailureSpec.scala | 14 +-
.../EventSourcedBehaviorInterceptorSpec.scala | 8 +-
.../EventSourcedBehaviorRecoveryTimeoutSpec.scala | 11 +-
.../scaladsl/EventSourcedBehaviorReplySpec.scala | 5 +-
.../EventSourcedBehaviorRetentionSpec.scala | 16 +-
.../scaladsl/EventSourcedBehaviorSignalSpec.scala | 14 +-
.../typed/scaladsl/EventSourcedBehaviorSpec.scala | 27 +-
.../scaladsl/EventSourcedBehaviorStashSpec.scala | 15 +-
.../scaladsl/EventSourcedBehaviorTimersSpec.scala | 8 +-
.../scaladsl/EventSourcedBehaviorWatchSpec.scala | 16 +-
.../scaladsl/EventSourcedEventAdapterSpec.scala | 6 +-
.../scaladsl/EventSourcedSequenceNumberSpec.scala | 6 +-
.../scaladsl/EventSourcedSnapshotAdapterSpec.scala | 6 +-
.../scaladsl/EventSourcedStashOverflowSpec.scala | 6 +-
.../typed/scaladsl/LoggerSourceSpec.scala | 6 +-
.../typed/scaladsl/NullEmptyStateSpec.scala | 4 +-
.../typed/scaladsl/OptionalSnapshotStoreSpec.scala | 5 +-
.../typed/scaladsl/PerformanceSpec.scala | 9 +-
.../typed/scaladsl/PrimitiveStateSpec.scala | 4 +-
.../typed/scaladsl/SlowInMemorySnapshotStore.scala | 8 +-
.../typed/scaladsl/SnapshotMutableStateSpec.scala | 8 +-
.../SnapshotRecoveryWithEmptyJournalSpec.scala | 13 +-
.../DurableStateBehaviorInterceptorSpec.scala | 10 +-
.../scaladsl/DurableStateBehaviorReplySpec.scala | 10 +-
.../DurableStateBehaviorStashOverflowSpec.scala | 10 +-
.../scaladsl/DurableStateBehaviorTimersSpec.scala | 12 +-
.../state/scaladsl/DurableStateRevisionSpec.scala | 9 +-
.../typed/state/scaladsl/NullEmptyStateSpec.scala | 7 +-
.../typed/state/scaladsl/PrimitiveStateSpec.scala | 7 +-
.../pekko/persistence/typed/EventAdapter.scala | 2 +-
.../pekko/persistence/typed/crdt/ORSet.scala | 9 +-
.../typed/delivery/EventSourcedProducerQueue.scala | 18 +-
.../persistence/typed/internal/BehaviorSetup.scala | 10 +-
.../typed/internal/EventSourcedBehaviorImpl.scala | 13 +-
.../typed/internal/EventSourcedSettings.scala | 4 +-
.../typed/internal/ExternalInteractions.scala | 16 +-
.../typed/internal/ReplayingEvents.scala | 13 +-
.../typed/internal/ReplayingSnapshot.scala | 10 +-
.../typed/internal/ReplicationSetup.scala | 3 +-
.../typed/internal/RequestingRecoveryPermit.scala | 5 +-
.../pekko/persistence/typed/internal/Running.scala | 32 +-
.../persistence/typed/internal/VersionVector.scala | 1 +
.../persistence/typed/javadsl/CommandHandler.scala | 3 +-
.../typed/javadsl/CommandHandlerWithReply.scala | 3 +-
.../pekko/persistence/typed/javadsl/Effect.scala | 3 +-
.../persistence/typed/javadsl/EventHandler.scala | 2 +-
.../typed/javadsl/EventSourcedBehavior.scala | 15 +-
.../typed/javadsl/PersistentFSMMigration.scala | 7 +-
.../typed/javadsl/ReplicatedEventSourcing.scala | 7 +-
.../typed/scaladsl/EventSourcedBehavior.scala | 5 +-
.../ReplicatedEventSourcingSerializer.scala | 14 +-
.../typed/state/internal/BehaviorSetup.scala | 12 +-
.../state/internal/DurableStateBehaviorImpl.scala | 9 +-
.../state/internal/DurableStateSettings.scala | 6 +-
.../internal/DurableStateStoreInteractions.scala | 8 +-
.../typed/state/internal/Recovering.scala | 9 +-
.../state/internal/RequestingRecoveryPermit.scala | 5 +-
.../persistence/typed/state/internal/Running.scala | 10 +-
.../typed/state/javadsl/CommandHandler.scala | 5 +-
.../state/javadsl/CommandHandlerWithReply.scala | 5 +-
.../typed/state/javadsl/DurableStateBehavior.scala | 4 +-
.../persistence/typed/state/javadsl/Effect.scala | 2 +-
.../state/scaladsl/DurableStateBehavior.scala | 2 +-
.../persistence/typed/state/scaladsl/Effect.scala | 2 +-
.../typed/ClusterSingletonPersistenceSpec.scala | 7 +-
.../persistence/typed/ManyRecoveriesSpec.scala | 4 +-
.../persistence/typed/PersistenceIdSpec.scala | 4 +-
.../ReplicatedEventSourcingSerializationSpec.scala | 1 +
.../typed/StashingWhenSnapshottingSpec.scala | 7 +-
.../delivery/EventSourcedProducerQueueSpec.scala | 9 +-
...DeliveryWithEventSourcedProducerQueueSpec.scala | 9 +-
...kPullingWithEventSourcedProducerQueueSpec.scala | 10 +-
.../typed/internal/RecoveryPermitterSpec.scala | 4 +-
.../typed/internal/RetentionCriteriaSpec.scala | 8 +-
.../typed/internal/StashStateSpec.scala | 4 +-
.../scaladsl/PersistentActorCompileOnlyTest.scala | 10 +-
.../typed/scaladsl/SnapshotIsOptionalSpec.scala | 8 +-
.../ReplicatedEventSourcingSerializerSpec.scala | 1 +
.../pekko/persistence/AtLeastOnceDelivery.scala | 6 +-
.../apache/pekko/persistence/Eventsourced.scala | 8 +-
.../org/apache/pekko/persistence/Persistence.scala | 6 +-
.../pekko/persistence/PersistencePlugin.scala | 4 +-
.../apache/pekko/persistence/PersistentActor.scala | 6 +-
.../pekko/persistence/fsm/PersistentFSM.scala | 11 +-
.../pekko/persistence/fsm/PersistentFSMBase.scala | 14 +-
.../pekko/persistence/journal/EventAdapters.scala | 10 +-
.../journal/PersistencePluginProxy.scala | 4 +-
.../apache/pekko/persistence/journal/Tagged.scala | 3 +-
.../persistence/journal/inmem/InmemJournal.scala | 13 +-
.../persistence/journal/japi/AsyncRecovery.scala | 8 +-
.../journal/japi/AsyncWriteJournal.scala | 12 +-
.../journal/leveldb/LeveldbIdMapping.scala | 5 +-
.../journal/leveldb/LeveldbJournal.scala | 6 +-
.../persistence/journal/leveldb/LeveldbStore.scala | 5 +-
.../journal/leveldb/SharedLeveldbStore.scala | 4 +-
.../serialization/MessageSerializer.scala | 10 +-
.../persistence/snapshot/japi/SnapshotStore.scala | 17 +-
.../snapshot/local/LocalSnapshotStore.scala | 6 +-
.../state/DurableStateStoreRegistry.scala | 8 +-
.../state/javadsl/DurableStateStore.scala | 3 +-
.../state/scaladsl/DurableStateStore.scala | 2 +-
.../AtLeastOnceDeliveryFailureSpec.scala | 4 +-
.../persistence/EndToEndEventAdapterSpec.scala | 23 +-
.../pekko/persistence/EventAdapterSpec.scala | 4 +-
.../apache/pekko/persistence/LoadPluginSpec.scala | 8 +-
.../pekko/persistence/ManyRecoveriesSpec.scala | 4 +-
.../persistence/OptionalSnapshotStoreSpec.scala | 4 +-
.../apache/pekko/persistence/PerformanceSpec.scala | 4 +-
.../apache/pekko/persistence/PersistenceSpec.scala | 8 +-
.../PersistentActorBoundedStashingSpec.scala | 7 +-
.../PersistentActorJournalProtocolSpec.scala | 4 +-
.../PersistentActorRecoveryTimeoutSpec.scala | 4 +-
.../pekko/persistence/PersistentActorSpec.scala | 6 +-
.../persistence/PersistentActorStashingSpec.scala | 8 +-
.../pekko/persistence/RecoveryPermitterSpec.scala | 4 +-
.../SnapshotFailureRobustnessSpec.scala | 4 +-
.../persistence/TimerPersistentActorSpec.scala | 4 +-
.../pekko/persistence/fsm/PersistentFSMSpec.scala | 5 +-
.../AsyncWriteJournalResponseOrderSpec.scala | 6 +-
.../journal/InmemEventAdaptersSpec.scala | 5 +-
.../persistence/journal/SteppingInmemJournal.scala | 4 +-
.../journal/leveldb/JournalCompactionSpec.scala | 3 +-
.../SnapshotSerializerMigrationAkkaSpec.scala | 7 +-
.../SnapshotSerializerNoMigrationSpec.scala | 6 +-
.../serialization/SnapshotSerializerSpec.scala | 4 +-
.../exception/DurableStateExceptionsSpec.scala | 2 +-
.../apache/pekko/pki/pem/DERPrivateKeyLoader.scala | 7 +-
.../src/main/resources/plugin.properties | 1 -
.../src/main/scala/org/apache/pekko/Plugin.scala | 51 -
project/CopyrightHeader.scala | 2 +-
project/CopyrightHeaderForBoilerplate.scala | 2 +-
project/CopyrightHeaderForBuild.scala | 2 +-
project/CopyrightHeaderForJdk9.scala | 2 +-
project/CopyrightHeaderForProtobuf.scala | 2 +-
project/Dependencies.scala | 47 +-
project/Doc.scala | 2 -
project/Jdk9.scala | 5 +-
project/JdkOptions.scala | 10 +-
project/MultiNode.scala | 4 +-
project/OSGi.scala | 21 +-
project/PekkoBuild.scala | 2 +-
project/PekkoDisciplinePlugin.scala | 2 +-
project/ProjectFileIgnoreSupport.scala | 4 +-
project/ScalaFixExtraRulesPlugin.scala | 5 +-
project/build.properties | 2 +-
project/plugins.sbt | 6 +-
project/project-info.conf | 2 +-
.../pekko/remote/AttemptSysMsgRedeliverySpec.scala | 3 +-
.../pekko/remote/LookupRemoteActorSpec.scala | 3 +-
.../apache/pekko/remote/NewRemoteActorSpec.scala | 7 +-
.../remote/PiercingShouldKeepQuarantineSpec.scala | 4 +-
.../apache/pekko/remote/RemoteDeliverySpec.scala | 4 +-
.../remote/RemoteDeploymentDeathWatchSpec.scala | 4 +-
.../apache/pekko/remote/RemoteFeaturesSpec.scala | 4 +-
.../pekko/remote/RemoteNodeDeathWatchSpec.scala | 4 +-
.../remote/RemoteNodeRestartDeathWatchSpec.scala | 4 +-
.../remote/RemoteQuarantinePiercingSpec.scala | 4 +-
.../pekko/remote/RemoteReDeploymentSpec.scala | 4 +-
.../pekko/remote/RemotingMultiNodeSpec.scala | 7 +-
.../apache/pekko/remote/TransportFailSpec.scala | 12 +-
.../pekko/remote/artery/DirectMemorySpec.scala | 4 +-
.../pekko/remote/artery/FanInThrougputSpec.scala | 4 +-
.../pekko/remote/artery/FanOutThrougputSpec.scala | 4 +-
.../artery/HandshakeRestartReceiverSpec.scala | 4 +-
.../apache/pekko/remote/artery/LatencySpec.scala | 3 +-
.../pekko/remote/artery/MaxThroughputSpec.scala | 3 +-
.../artery/RemoteRestartedQuarantinedSpec.scala | 4 +-
...dStreamRestartWithCompressionInFlightSpec.scala | 7 +-
.../artery/SurviveNetworkPartitionSpec.scala | 6 +-
.../apache/pekko/remote/artery/TestMessage.scala | 6 +-
.../artery/aeron/AeronStreamConcistencySpec.scala | 3 +-
.../artery/aeron/AeronStreamLatencySpec.scala | 3 +-
.../aeron/AeronStreamMaxThroughputSpec.scala | 3 +-
.../remote/classic/RemoteGatePiercingSpec.scala | 6 +-
.../remote/classic/RemoteNodeRestartGateSpec.scala | 6 +-
.../RemoteNodeShutdownAndComesBackSpec.scala | 4 +-
.../pekko/remote/classic/Ticket15109Spec.scala | 6 +-
.../pekko/remote/routing/RemoteRandomSpec.scala | 4 +-
.../remote/routing/RemoteRoundRobinSpec.scala | 4 +-
.../remote/routing/RemoteScatterGatherSpec.scala | 4 +-
.../remote/testconductor/TestConductorSpec.scala | 4 +-
.../remote/artery/ArteryFailedToBindSpec.scala | 9 +-
.../remote/classic/RemotingFailedToBindSpec.scala | 10 +-
.../remote/testconductor/ControllerSpec.scala | 2 +-
.../org/apache/pekko/remote/ByteStringUtils.scala | 2 +-
.../pekko/remote/DeadlineFailureDetector.scala | 4 +-
.../scala/org/apache/pekko/remote/Endpoint.scala | 5 +-
.../pekko/remote/FailureDetectorRegistry.scala | 4 +-
.../apache/pekko/remote/MessageSerializer.scala | 7 +-
.../pekko/remote/PhiAccrualFailureDetector.scala | 5 +-
.../pekko/remote/RemoteActorRefProvider.scala | 7 +-
.../org/apache/pekko/remote/RemoteDaemon.scala | 2 +-
.../org/apache/pekko/remote/RemoteDeployer.scala | 5 +-
.../pekko/remote/RemoteMetricsExtension.scala | 3 +-
.../org/apache/pekko/remote/RemoteSettings.scala | 10 +-
.../org/apache/pekko/remote/RemoteTransport.scala | 7 +-
.../org/apache/pekko/remote/RemoteWatcher.scala | 6 +-
.../scala/org/apache/pekko/remote/Remoting.scala | 11 +-
.../pekko/remote/RemotingLifecycleEvent.scala | 2 +-
.../pekko/remote/artery/ArterySettings.scala | 12 +-
.../pekko/remote/artery/ArteryTransport.scala | 3 +-
.../apache/pekko/remote/artery/Association.scala | 4 +-
.../org/apache/pekko/remote/artery/Codecs.scala | 10 +-
.../org/apache/pekko/remote/artery/Control.scala | 1 +
.../pekko/remote/artery/EnvelopeBufferPool.scala | 2 +
.../pekko/remote/artery/FlushOnShutdown.scala | 1 +
.../org/apache/pekko/remote/artery/Handshake.scala | 8 +-
.../pekko/remote/artery/RemoteInstrument.scala | 12 +-
.../remote/artery/SystemMessageDelivery.scala | 4 +-
.../org/apache/pekko/remote/artery/TestStage.scala | 2 +
.../artery/aeron/ArteryAeronUdpTransport.scala | 2 -
.../remote/artery/compress/CompressionTable.scala | 4 +-
.../artery/compress/InboundCompressions.scala | 6 +-
.../remote/artery/tcp/ArteryTcpTransport.scala | 5 +-
.../artery/tcp/ConfigSSLEngineProvider.scala | 19 +-
.../remote/artery/tcp/SSLEngineProvider.scala | 7 +-
.../remote/artery/tcp/SecureRandomFactory.scala | 1 +
.../artery/tcp/ssl/PemManagersProvider.scala | 7 +-
.../tcp/ssl/RotatingKeysSSLEngineProvider.scala | 15 +-
.../remote/artery/tcp/ssl/SSLEngineConfig.scala | 9 +-
.../remote/artery/tcp/ssl/SessionVerifier.scala | 2 +-
.../pekko/remote/artery/tcp/ssl/X509Readers.scala | 5 +-
.../pekko/remote/routing/RemoteRouterConfig.scala | 5 +-
.../serialization/ActorRefResolveCache.scala | 4 +-
.../serialization/ArteryMessageSerializer.scala | 6 +-
.../serialization/DaemonMsgCreateSerializer.scala | 10 +-
.../serialization/MessageContainerSerializer.scala | 5 +-
.../serialization/MiscMessageSerializer.scala | 6 +-
.../remote/serialization/ProtobufSerializer.scala | 2 +-
.../remote/serialization/ThrowableSupport.scala | 2 +-
.../serialization/WrappedPayloadSupport.scala | 6 +-
.../FailureInjectorTransportAdapter.scala | 2 +-
.../pekko/remote/transport/PekkoPduCodec.scala | 3 +-
.../remote/transport/PekkoProtocolTransport.scala | 8 +-
.../pekko/remote/transport/TestTransport.scala | 4 +-
.../transport/ThrottlerTransportAdapter.scala | 9 +-
.../apache/pekko/remote/transport/Transport.scala | 7 +-
.../remote/transport/netty/NettyHelpers.scala | 13 +-
.../remote/transport/netty/NettySSLSupport.scala | 9 +-
.../remote/transport/netty/NettyTransport.scala | 9 +-
.../pekko/remote/AccrualFailureDetectorSpec.scala | 3 +-
.../apache/pekko/remote/AckedDeliverySpec.scala | 3 +-
.../org/apache/pekko/remote/DaemonicSpec.scala | 8 +-
.../apache/pekko/remote/MessageLoggingSpec.scala | 5 +-
.../apache/pekko/remote/NetworkFailureSpec.scala | 2 +-
.../pekko/remote/RemoteActorMailboxSpec.scala | 4 +-
.../org/apache/pekko/remote/RemoteConfigSpec.scala | 6 +-
.../apache/pekko/remote/RemoteDeployerSpec.scala | 4 +-
.../apache/pekko/remote/RemoteFeaturesSpec.scala | 8 +-
.../org/apache/pekko/remote/RemoteRouterSpec.scala | 4 +-
.../pekko/remote/Ticket1978CommunicationSpec.scala | 6 +-
.../remote/TransientSerializationErrorSpec.scala | 7 +-
.../ActorRefResolveCacheQuarantineSpec.scala | 4 +-
.../pekko/remote/artery/ArteryMultiNodeSpec.scala | 7 +-
.../remote/artery/BindCanonicalAddressSpec.scala | 9 +-
.../pekko/remote/artery/DuplicateFlushSpec.scala | 2 +-
.../remote/artery/DuplicateHandshakeSpec.scala | 2 +-
.../pekko/remote/artery/EnvelopeBufferSpec.scala | 1 +
.../pekko/remote/artery/HandshakeDenySpec.scala | 4 +-
.../pekko/remote/artery/HandshakeFailureSpec.scala | 4 +-
.../pekko/remote/artery/HandshakeRetrySpec.scala | 4 +-
.../remote/artery/HarmlessQuarantineSpec.scala | 6 +-
.../pekko/remote/artery/ImmutableLongMapSpec.scala | 4 +-
.../remote/artery/InboundControlJunctionSpec.scala | 2 +-
.../pekko/remote/artery/InboundHandshakeSpec.scala | 2 +-
.../pekko/remote/artery/LateConnectSpec.scala | 4 +-
.../pekko/remote/artery/LruBoundedCacheSpec.scala | 3 +-
.../artery/OutboundControlJunctionSpec.scala | 2 +-
.../remote/artery/OutboundHandshakeSpec.scala | 2 +-
.../remote/artery/OutboundIdleShutdownSpec.scala | 6 +-
.../pekko/remote/artery/RemoteDeathWatchSpec.scala | 6 +-
.../pekko/remote/artery/RemoteDeployerSpec.scala | 4 +-
.../pekko/remote/artery/RemoteDeploymentSpec.scala | 4 +-
.../RemoteInstrumentsSerializationSpec.scala | 10 +-
.../remote/artery/RemoteInstrumentsSpec.scala | 3 +-
.../artery/RemoteMessageSerializationSpec.scala | 3 +-
.../pekko/remote/artery/RemoteRouterSpec.scala | 4 +-
.../remote/artery/RemoteSendConsistencySpec.scala | 4 +-
.../pekko/remote/artery/RemoteWatcherSpec.scala | 4 +-
.../remote/artery/RemotingFlightRecorderSpec.scala | 4 +-
.../apache/pekko/remote/artery/SendQueueSpec.scala | 2 +-
.../remote/artery/SystemMessageAckerSpec.scala | 2 +-
.../remote/artery/SystemMessageDeliverySpec.scala | 6 +-
.../apache/pekko/remote/artery/TestContext.scala | 8 +-
.../apache/pekko/remote/artery/UntrustedSpec.scala | 4 +-
.../pekko/remote/artery/aeron/AeronSinkSpec.scala | 2 +-
.../compress/CompressionIntegrationSpec.scala | 6 +-
.../HandshakeShouldDropCompressionTableSpec.scala | 7 +-
.../artery/jfr/JFRRemotingFlightRecorderSpec.scala | 4 +-
.../pekko/remote/artery/tcp/TcpFramingSpec.scala | 2 +-
.../pekko/remote/artery/tcp/TlsTcpSpec.scala | 14 +-
.../artery/tcp/ssl/CipherSuiteSupportCheck.scala | 7 +-
.../artery/tcp/ssl/PeerSubjectVerifierSpec.scala | 2 +-
.../artery/tcp/ssl/PemManagersProviderSpec.scala | 1 +
.../ssl/RotatingKeysSSLEngineProviderSpec.scala | 13 +-
.../remote/artery/tcp/ssl/TlsResourcesSpec.scala | 7 +-
.../pekko/remote/classic/ActorsLeakSpec.scala | 6 +-
.../remote/classic/RemoteDeathWatchSpec.scala | 6 +-
.../classic/RemoteDeploymentAllowListSpec.scala | 6 +-
.../pekko/remote/classic/RemoteInitErrorSpec.scala | 9 +-
.../pekko/remote/classic/RemoteSettingsSpec.scala | 8 +-
.../pekko/remote/classic/RemoteWatcherSpec.scala | 3 +-
.../apache/pekko/remote/classic/RemotingSpec.scala | 3 +-
.../pekko/remote/classic/UntrustedSpec.scala | 6 +-
.../classic/transport/GenericTransportSpec.scala | 3 +-
.../classic/transport/PekkoProtocolSpec.scala | 8 +-
.../transport/PekkoProtocolStressTest.scala | 4 +-
.../SystemMessageDeliveryStressTest.scala | 6 +-
.../classic/transport/TestTransportSpec.scala | 3 +-
.../transport/ThrottlerTransportAdapterSpec.scala | 6 +-
.../AllowJavaSerializationOffSpec.scala | 4 +-
.../ArteryMessageSerializerSpec.scala | 4 +-
...reateSerializerAllowJavaSerializationSpec.scala | 14 +-
.../serialization/MiscMessageSerializerSpec.scala | 5 +-
.../serialization/ProtobufSerializerSpec.scala | 11 +-
.../SerializationTransportInformationSpec.scala | 9 +-
.../SystemMessageSerializationSpec.scala | 4 +-
.../remote/transport/NettyTransportSpec.scala | 14 +-
scripts/find-javadoc-error.pl | 15 -
.../jackson/FiniteDurationModule.scala | 6 +-
.../serialization/jackson/JacksonMigration.scala | 6 +-
.../jackson/JacksonObjectMapperProvider.scala | 41 +-
.../serialization/jackson/JacksonSerializer.scala | 4 +-
.../jackson/PekkoSerializationModule.scala | 1 +
.../serialization/jackson/JacksonFactorySpec.scala | 11 +-
.../jackson/JacksonSerializerSpec.scala | 16 +-
.../org/apache/pekko/event/slf4j/Slf4jLogger.scala | 8 +-
.../apache/pekko/event/slf4j/Slf4jLoggerSpec.scala | 6 +-
.../pekko/event/slf4j/Slf4jLoggingFilterSpec.scala | 4 +-
.../pekko/stream/testkit/StreamTestKit.scala | 40 +-
.../stream/testkit/javadsl/StreamTestKit.scala | 9 +-
.../pekko/stream/testkit/StreamConfiguration.scala | 5 +-
.../apache/pekko/stream/testkit/StreamSpec.scala | 4 +-
.../pekko/stream/tck/ActorSystemLifecycle.scala | 7 +-
.../stream/tck/CancelledSinkSubscriberTest.scala | 3 +-
.../org/apache/pekko/stream/tck/ConcatTest.scala | 4 +-
.../pekko/stream/tck/EmptyPublisherTest.scala | 4 +-
.../pekko/stream/tck/FanoutPublisherTest.scala | 4 +-
.../pekko/stream/tck/FilePublisherTest.scala | 3 +-
.../tck/FlatMapConcatDoubleSubscriberTest.scala | 4 +-
.../pekko/stream/tck/FlatMapPrefixTest.scala | 4 +-
.../org/apache/pekko/stream/tck/FlattenTest.scala | 4 +-
.../pekko/stream/tck/FoldSinkSubscriberTest.scala | 4 +-
.../stream/tck/ForeachSinkSubscriberTest.scala | 4 +-
.../pekko/stream/tck/FusableProcessorTest.scala | 4 +-
.../pekko/stream/tck/FuturePublisherTest.scala | 4 +-
.../org/apache/pekko/stream/tck/GroupByTest.scala | 4 +-
.../pekko/stream/tck/InputStreamSourceTest.scala | 4 +-
.../pekko/stream/tck/IterablePublisherTest.scala | 4 +-
...IterablePublisherViaJavaFlowPublisherTest.scala | 3 +-
.../org/apache/pekko/stream/tck/MapTest.scala | 4 +-
.../apache/pekko/stream/tck/MaybeSourceTest.scala | 4 +-
.../tck/PekkoIdentityProcessorVerification.scala | 7 +-
.../stream/tck/PekkoPublisherVerification.scala | 10 +-
.../stream/tck/PekkoSubscriberVerification.scala | 7 +-
.../pekko/stream/tck/PrefixAndTailTest.scala | 4 +-
.../pekko/stream/tck/SingleElementSourceTest.scala | 4 +-
.../pekko/stream/tck/SinkholeSubscriberTest.scala | 7 +-
.../apache/pekko/stream/tck/SplitWhenTest.scala | 4 +-
.../pekko/stream/tck/TransformProcessorTest.scala | 4 +-
.../pekko/stream/tck/VirtualPublisherTest.scala | 4 +-
.../org/apache/pekko/stream/javadsl/FlowTest.java | 88 +-
.../org/apache/pekko/stream/javadsl/SinkTest.java | 18 +
.../apache/pekko/stream/javadsl/SourceTest.java | 149 ++
.../pekko/stream/ActorMaterializerSpec.scala | 4 +-
.../apache/pekko/stream/DslConsistencySpec.scala | 6 +-
.../pekko/stream/impl/SubInletOutletSpec.scala | 6 +-
.../pekko/stream/impl/TraversalBuilderSpec.scala | 8 +-
.../stream/impl/fusing/AsyncCallbackSpec.scala | 8 +-
.../apache/pekko/stream/io/DeprecatedTlsSpec.scala | 573 --------
.../org/apache/pekko/stream/io/FileSinkSpec.scala | 2 +-
.../apache/pekko/stream/io/FileSourceSpec.scala | 2 +-
.../pekko/stream/io/InputStreamSourceSpec.scala | 10 +-
.../pekko/stream/io/OutputStreamSinkSpec.scala | 4 +-
.../scala/org/apache/pekko/stream/io/TcpSpec.scala | 98 --
.../scala/org/apache/pekko/stream/io/TlsSpec.scala | 15 +-
.../io/compression/CompressionTestingTools.scala | 2 -
.../pekko/stream/scaladsl/AttributesSpec.scala | 2 +-
.../stream/scaladsl/FlowCollectFirstSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowDispatcherSpec.scala | 3 +-
.../stream/scaladsl/FlowDropRepeatedSpec.scala | 4 +-
.../FlowFlatMapConcatParallelismSpec.scala | 22 +-
.../FlowGroupedAdjacentByWeightedSpec.scala | 2 +-
.../stream/scaladsl/FlowGroupedWeightedSpec.scala | 8 +-
.../stream/scaladsl/FlowLimitWeightedSpec.scala | 8 +-
.../stream/scaladsl/FlowRecoverWithSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowSlidingSpec.scala | 4 +-
.../apache/pekko/stream/scaladsl/FlowSpec.scala | 2 +-
.../scaladsl/FlowStatefulMapConcatSpec.scala | 2 -
.../pekko/stream/scaladsl/FlowSwitchSpec.scala | 6 +-
.../stream/scaladsl/FlowWithContextSpec.scala | 5 +-
.../apache/pekko/stream/scaladsl/FramingSpec.scala | 6 +-
.../stream/scaladsl/GraphBackedFlowSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphUnzipWithSpec.scala | 4 +-
.../apache/pekko/stream/scaladsl/SinkSpec.scala | 18 +-
.../pekko/stream/scaladsl/SourceSinkSpec.scala | 87 ++
.../stream/scaladsl/SourceWithContextSpec.scala | 5 +-
.../stream/scaladsl/StreamConvertersSpec.scala | 4 +-
.../pekko/stream/scaladsl/TakeLastSinkSpec.scala | 4 +-
.../pekko/stream/MapAsyncPartitionedSpec.scala | 21 +-
.../javaapi-functions.excludes | 23 +-
.../pekko/stream/typed/javadsl/ActorFlow.scala | 27 +-
.../pekko/stream/typed/javadsl/ActorSource.scala | 5 +-
.../pekko/stream/typed/scaladsl/ActorFlow.scala | 7 +-
.../typed/scaladsl/ActorSourceSinkSpec.scala | 4 +-
.../typed/scaladsl/MaterializerForTypedSpec.scala | 4 +-
.../pekko/stream/typed/scaladsl/PubSubSpec.scala | 1 +
.../javaapi-functions.excludes | 27 +
.../remove-deprecated-methods.excludes | 12 +-
.../remove-ssl-config.excludes | 36 +-
stream/src/main/resources/reference.conf | 6 -
.../pekko/stream/javadsl/CollectionUtil.scala | 39 -
.../pekko/stream/javadsl/CollectionUtil.scala | 2 +-
.../pekko/stream/javadsl/CollectionUtil.scala | 2 +-
.../typesafe/sslconfig/pekko/PekkoSSLConfig.scala | 189 ---
.../sslconfig/pekko/SSLEngineConfigurator.scala | 44 -
.../sslconfig/pekko/util/PekkoLoggerBridge.scala | 44 -
.../apache/pekko/stream/ActorMaterializer.scala | 111 +-
.../scala/org/apache/pekko/stream/Attributes.scala | 16 +-
.../scala/org/apache/pekko/stream/KillSwitch.scala | 2 +-
.../apache/pekko/stream/MapAsyncPartitioned.scala | 4 +-
.../org/apache/pekko/stream/RestartSettings.scala | 20 +-
.../main/scala/org/apache/pekko/stream/Shape.scala | 2 +-
.../apache/pekko/stream/SystemMaterializer.scala | 10 +-
.../apache/pekko/stream/UniformFanInShape.scala | 2 +-
.../pekko/stream/impl/ActorMaterializerImpl.scala | 3 +-
.../apache/pekko/stream/impl/ActorProcessor.scala | 5 +-
.../scala/org/apache/pekko/stream/impl/FanIn.scala | 5 +-
.../org/apache/pekko/stream/impl/FanOut.scala | 4 +-
.../pekko/stream/impl/JavaStreamSource.scala | 6 +-
.../org/apache/pekko/stream/impl/MaybeSource.scala | 4 +-
.../impl/PhasedFusingActorMaterializer.scala | 2 +-
.../org/apache/pekko/stream/impl/QueueSource.scala | 3 +-
.../org/apache/pekko/stream/impl/SetupStage.scala | 141 +-
.../scala/org/apache/pekko/stream/impl/Sinks.scala | 12 +-
.../org/apache/pekko/stream/impl/Stages.scala | 2 +
.../pekko/stream/impl/TraversalBuilder.scala | 4 +-
.../org/apache/pekko/stream/impl/Unfold.scala | 2 +-
.../stream/impl/UnfoldResourceSourceAsync.scala | 2 +-
.../pekko/stream/impl/fusing/CountSink.scala | 66 +
.../pekko/stream/impl/fusing/DropRepeated.scala | 6 +-
.../pekko/stream/impl/fusing/FlattenConcat.scala | 14 +-
.../pekko/stream/impl/fusing/FutureFlow.scala | 4 +-
.../pekko/stream/impl/fusing/GraphStages.scala | 6 +-
.../impl/fusing/GroupedAdjacentByWeighted.scala | 6 +-
.../stream/impl/fusing/LazyFutureSource.scala | 4 +-
.../pekko/stream/impl/fusing/MapConcat.scala | 2 -
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 19 +-
.../pekko/stream/impl/fusing/SourceSink.scala | 121 ++
.../pekko/stream/impl/fusing/StreamOfStreams.scala | 2 +-
.../apache/pekko/stream/impl/fusing/Switch.scala | 2 +-
.../pekko/stream/impl/io/FileOutputStage.scala | 2 +-
.../org/apache/pekko/stream/impl/io/TLSActor.scala | 12 +-
.../apache/pekko/stream/impl/io/TcpStages.scala | 7 +-
.../apache/pekko/stream/impl/io/TlsModule.scala | 9 +-
.../org/apache/pekko/stream/javadsl/BidiFlow.scala | 4 +-
.../pekko/stream/javadsl/DelayStrategy.scala | 4 +-
.../org/apache/pekko/stream/javadsl/FileIO.scala | 3 +-
.../org/apache/pekko/stream/javadsl/Flow.scala | 185 ++-
.../pekko/stream/javadsl/FlowWithContext.scala | 16 +-
.../org/apache/pekko/stream/javadsl/Graph.scala | 39 +-
.../org/apache/pekko/stream/javadsl/Hub.scala | 29 +-
.../apache/pekko/stream/javadsl/MergeLatest.scala | 3 +-
.../org/apache/pekko/stream/javadsl/Queue.scala | 8 +-
.../apache/pekko/stream/javadsl/RetryFlow.scala | 11 +-
.../org/apache/pekko/stream/javadsl/Sink.scala | 77 +-
.../org/apache/pekko/stream/javadsl/Source.scala | 187 ++-
.../pekko/stream/javadsl/SourceWithContext.scala | 16 +-
.../javadsl/StatefulMapConcatAccumulator.scala | 9 +-
.../pekko/stream/javadsl/StreamConverters.scala | 7 +-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 73 +-
.../apache/pekko/stream/javadsl/SubSource.scala | 73 +-
.../org/apache/pekko/stream/javadsl/TLS.scala | 126 +-
.../org/apache/pekko/stream/javadsl/Tcp.scala | 182 +--
.../org/apache/pekko/stream/scaladsl/Flow.scala | 5 +-
.../pekko/stream/scaladsl/FlowWithContext.scala | 2 +-
.../pekko/stream/scaladsl/FlowWithContextOps.scala | 10 +-
.../org/apache/pekko/stream/scaladsl/Hub.scala | 33 +-
.../org/apache/pekko/stream/scaladsl/Queue.scala | 8 +-
.../org/apache/pekko/stream/scaladsl/Sink.scala | 49 +-
.../org/apache/pekko/stream/scaladsl/Source.scala | 2 +-
.../scaladsl/StatefulMapConcatAccumulator.scala | 8 +-
.../org/apache/pekko/stream/scaladsl/SubFlow.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/TLS.scala | 142 +-
.../org/apache/pekko/stream/scaladsl/Tcp.scala | 122 +-
.../org/apache/pekko/stream/scaladsl/package.scala | 3 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 67 +-
.../pekko/testkit/CallingThreadDispatcher.scala | 4 +-
.../testkit/ExplicitlyTriggeredScheduler.scala | 11 +-
.../org/apache/pekko/testkit/TestActorRef.scala | 3 +-
.../apache/pekko/testkit/TestEventListener.scala | 2 -
.../scala/org/apache/pekko/testkit/TestKit.scala | 5 +-
.../apache/pekko/testkit/TestKitExtension.scala | 4 +-
.../org/apache/pekko/testkit/javadsl/TestKit.scala | 56 +-
.../scala/org/apache/pekko/testkit/package.scala | 2 -
.../apache/pekko/testkit/DefaultTimeoutSpec.scala | 4 +-
.../apache/pekko/testkit/ImplicitSenderSpec.scala | 4 +-
.../scala/org/apache/pekko/testkit/PekkoSpec.scala | 23 +-
.../org/apache/pekko/testkit/PekkoSpecSpec.scala | 14 +-
.../apache/pekko/testkit/TestActorRefSpec.scala | 4 +-
.../org/apache/pekko/testkit/TestProbeSpec.scala | 4 +-
.../apache/pekko/testkit/WithLogCapturing.scala | 4 +-
.../testkit/metrics/FileDescriptorMetricSet.scala | 4 +-
.../apache/pekko/testkit/metrics/MetricsKit.scala | 15 +-
.../pekko/testkit/metrics/MetricsKitOps.scala | 3 +-
.../pekko/testkit/metrics/MetricsKitSpec.scala | 3 +-
.../metrics/reporter/PekkoConsoleReporter.scala | 2 +-
1470 files changed, 7006 insertions(+), 12316 deletions(-)
copy .github/workflows/{nightly-1.2-builds.yml => nightly-1.3-builds.yml} (93%)
copy .github/workflows/{publish-1.1-nightly.yml => publish-1.3-nightly.yml}
(92%)
delete mode 100755 actor-tests/src/test/bind/etc/db.0
delete mode 100755 actor-tests/src/test/bind/etc/db.127
delete mode 100755 actor-tests/src/test/bind/etc/db.255
mode change 100755 => 100644 actor-tests/src/test/bind/etc/db.bar.example
delete mode 100755 actor-tests/src/test/bind/etc/db.empty
mode change 100755 => 100644 actor-tests/src/test/bind/etc/db.foo.test
delete mode 100755 actor-tests/src/test/bind/etc/db.local
delete mode 100755 actor-tests/src/test/bind/etc/db.root
delete mode 100755 actor-tests/src/test/bind/etc/named.conf
delete mode 100755 actor-tests/src/test/bind/etc/named.conf.default-zones
mode change 100755 => 100644 actor-tests/src/test/bind/etc/named.conf.local
mode change 100755 => 100644 actor-tests/src/test/bind/etc/named.conf.options
delete mode 100755 actor-tests/src/test/bind/etc/rndc.key
mode change 100755 => 100644 actor-tests/src/test/bind/etc/zones.rfc1918
create mode 100644
actor-tests/src/test/java-jdk21-only/org/apache/pekko/actor/StashJavaAPITestUntypedActors.java
copy actor-tests/src/test/{java/org/apache/pekko/actor/StashJavaAPI.java =>
java-jdk21-only/org/apache/pekko/actor/UntypedStashJavaAPI.java} (75%)
create mode 100644
actor-tests/src/test/java/org/apache/pekko/japi/FunctionLawTest.java
delete mode 100644
actor-tests/src/test/java/org/apache/pekko/util/JavaConverterScala3InlineTest.java
copy
actor-tests/src/test/scala-jdk21-only/org/apache/pekko/dispatch/{ForkJoinPoolVirtualThreadSpec.scala
=> ThreadPoolVirtualThreadSpec.scala} (59%)
rename actor-tests/src/test/{scala-2.13+ =>
scala}/org/apache/pekko/util/ByteStringBuilderScala213PlusSpec.scala (100%)
delete mode 100644
actor-tests/src/test/scala/org/apache/pekko/util/Scala212CompatTest.scala
delete mode 100644
actor-typed/src/main/scala-2.12/org/apache/pekko/actor/typed/internal/receptionist/Platform.scala
copy
stream/src/main/mima-filters/1.0.x.backwards.excludes/pr-1374-boundedsourcequeue-iscompleted-classes.backwards.excludes
=>
actor/src/main/mima-filters/1.2.x.backwards.excludes/bytestring-indexOf-overload.excludes
(89%)
rename actor/src/main/mima-filters/{1.1.x.backwards.excludes =>
2.0.x.backwards.excludes}/backoff-calculation.excludes (82%)
copy actor-typed/src/main/mima-filters/1.0.x.backwards.excludes/jfr.excludes
=>
actor/src/main/mima-filters/2.0.x.backwards.excludes/function-converters.excludes
(74%)
delete mode 100644
actor/src/main/mima-filters/2.0.x.backwards.excludes/option-converters.excludes
create mode 100644
actor/src/main/mima-filters/2.0.x.backwards.excludes/remove-scala-2.12-support.excludes
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/compat/Future.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/compat/PartialFunction.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/dispatch/internal/ScalaBatchable.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/ByteIterator.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/ByteString.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/FunctionConverters.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/FutureConverters.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/OptionConverters.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/ccompat/CompatImpl.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/ccompat/ccompatUsedUntil213.scala
delete mode 100644
actor/src/main/scala-2.12/org/apache/pekko/util/ccompat/package.scala
delete mode 100644
actor/src/main/scala-2.13+/org/apache/pekko/compat/Future.scala
delete mode 100644
actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala
delete mode 100644
actor/src/main/scala-2.13+/org/apache/pekko/util/ccompat/ccompatUsedUntil213.scala
delete mode 100644
actor/src/main/scala-2.13+/org/apache/pekko/util/ccompat/package.scala
delete mode 100644
actor/src/main/scala-2.13/org/apache/pekko/compat/PartialFunction.scala
delete mode 100644
actor/src/main/scala-2.13/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644
actor/src/main/scala-2.13/org/apache/pekko/util/ByteString.scala
delete mode 100644
actor/src/main/scala-2.13/org/apache/pekko/util/FutureConverters.scala
delete mode 100644
actor/src/main/scala-2.13/org/apache/pekko/util/OptionConverters.scala
delete mode 100644
actor/src/main/scala-2/org/apache/pekko/util/JavaDurationConverters.scala
delete mode 100644
actor/src/main/scala-3/org/apache/pekko/compat/PartialFunction.scala
delete mode 100644
actor/src/main/scala-3/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644
actor/src/main/scala-3/org/apache/pekko/util/FutureConverters.scala
delete mode 100644
actor/src/main/scala-3/org/apache/pekko/util/JavaDurationConverters.scala
delete mode 100644
actor/src/main/scala-3/org/apache/pekko/util/OptionConverters.scala
rename actor/src/main/{scala-3 =>
scala}/org/apache/pekko/util/ByteString.scala (95%)
delete mode 100644 actor/src/main/scala/org/apache/pekko/util/Unused.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/BroadcastHubBenchmark.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_lastIndexOf_Benchmark.scala
delete mode 100644
bench-jmh/src/main/scala/org/apache/pekko/util/StackBench.scala
delete mode 100644
cluster-typed/src/main/scala-2.12/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionistProtocol.scala
create mode 100644 docs/src/main/paradox/stream/operators/Sink/count.md
create mode 100644 docs/src/main/paradox/stream/operators/Sink/source.md
create mode 100644
docs/src/main/paradox/stream/operators/Source-or-Flow/onErrorResume.md
delete mode 100644
plugins/serialversion-remover-plugin/src/main/resources/plugin.properties
delete mode 100644
plugins/serialversion-remover-plugin/src/main/scala/org/apache/pekko/Plugin.scala
delete mode 100755 scripts/find-javadoc-error.pl
rename stream-tests-tck/src/test/{scala-jdk9-only =>
scala}/org/apache/pekko/stream/tck/IterablePublisherViaJavaFlowPublisherTest.scala
(94%)
delete mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/io/DeprecatedTlsSpec.scala
create mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SourceSinkSpec.scala
copy
persistence/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes
=>
stream-typed/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes
(64%)
copy
cluster/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes
=>
stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-ssl-config.excludes
(57%)
delete mode 100644
stream/src/main/scala-2.12/org/apache/pekko/stream/javadsl/CollectionUtil.scala
delete mode 100644
stream/src/main/scala/com/typesafe/sslconfig/pekko/PekkoSSLConfig.scala
delete mode 100644
stream/src/main/scala/com/typesafe/sslconfig/pekko/SSLEngineConfigurator.scala
delete mode 100644
stream/src/main/scala/com/typesafe/sslconfig/pekko/util/PekkoLoggerBridge.scala
create mode 100644
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/CountSink.scala
create mode 100644
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
