This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch feature/artery-frequency-sketch
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit 2bfe10525a chore: remove unrelated files and fix stale Scaladoc
omit 9dacae50aa style: apply scalafmt formatting
omit 83cd9ae3a6 fix: address review feedback - keep CountMinSketch and make
configurable
omit 4bb836ec96 fix: add MiMa exclusion for removed CountMinSketch INTERNAL
API class
omit 7e26f89c1b feat: replace CountMinSketch with FastFrequencySketch in
Artery compression
add 42a4596780 fix: guard against int overflow in supervisor strategy and
frequency sketch (#3022)
add 7c1d0a623d Fix sbt load warnings by excluding unused lint keys (#3029)
add bbb1e8efc9 chore(stream): remove dead ActorProcessor,
ActorProcessorImpl, and ExposedPublisherReceive (#3027)
add 4e1508c38d chore(deps): bump sbt/setup-sbt from 1.1.24 to 1.2.1 (#3034)
add fbc05e26e8 chore(deps): bump scalacenter/sbt-dependency-submission
(#3033)
add e04e721ab6 Replace Scala string interpolation in log calls with lazy
{} placeholder format (#3032)
add a30df08865 2.0.0-M3 release notes (#3014)
add 27f6960dda ClusterShardingSettings: remove backward-compat passivation
cruft (#3026)
add 3e7b5e9257 Update netty-handler, netty-transport to 4.2.15.Final
(#3039)
add e012dd39ab Update logback-classic to 1.5.34 (#3038)
add 1dc09320aa fix: add missing space in StageActor PoisonPill/Kill
warning message (#3040)
add 153c151950 fix: widen RemoteSendConsistencySpec await window to 30s
(#3041)
add f6f988235b regenerate protobuf classes with protoc 4.35.0 (#3042)
add 70f6bbda56 Update biz.aQute.bndlib to 7.3.0 (#3044)
add 6f6fc8b7b5 Update jackson-core to 2.22.0 (#3045)
add 9a56d49ceb Update typesafe:config to 1.4.9 (#3046)
add 29dc5e8df3 chore: Rewrite to scala3 syntax (#3048)
add ca4b3aec02 test: retry temporary port bind in RemotingSpec
lazy-connect test (#3015)
add 6371e5b4be chore(deps): bump actions/checkout from 6.0.2 to 6.0.3
(#3053)
add bf96f5afa6 fix: correct typos in comments, docs, and string literals
across codebase (#3055)
add 0fc6120ddd Update Scala 3 version to 3.3.8 (#3056)
add 718c3f5675 Update protobuf-java to 4.35.1 (#3057)
add 52234c0199 Fix unresolvable scaladoc links to the ShardRegion actor
#353 (#3064)
add bf54798054 Add -Yfuture-lazy-vals for Scala 3.3.x builds (#3059)
add 28d61c5368 perf: replace ArrayList consumer wheel with LongMap for
O(1) keyed removal (#3063)
add 03ebaf59bb perf: optimize stream materializer wiring with HashMap and
ArrayList replacements (#3062)
add 645b76fbc9 Runtime plugin configuration for DurableState (#3058)
add b3219211ee Update sbt, scripted-plugin to 1.12.12 (#3069)
add 83e45001d2 Update sbt-api-mappings to 3.0.3 (#3068)
add f253c25de6 Update sbt-scalafix to 0.14.7 (#3067)
add 3e578d8a75 chore: upgrade sbt-java-formatter to 0.12.0 (#3066)
add f42ab033ab Update jackson-core to 3.2.0 (#3054)
add 400354ee8f aeron 1.51.0 (#3070)
add ba4e950edb Optimize lazy stage actor dispatch (#3035)
add ee6965cd58 fix: Scala 3.8 syntax compat fixes and import cleanup
(#3074)
add 6482aa1d9f refactor: rename Jdk9 sbt plugin to Jdk21 to reflect actual
purpose (#3075)
add 8a09821cc5 Add TCK tests for replay bounds across a deletion gap
(#3076)
add eb1fd145ee feat: replace CountMinSketch with FastFrequencySketch in
Artery compression
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2bfe10525a)
\
N -- N -- N refs/heads/feature/artery-frequency-sketch
(eb1fd145ee)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/binary-compatibility-checks.yml | 4 +-
.github/workflows/build-test-prValidation.yml | 24 +-
.github/workflows/dependency-graph.yml | 8 +-
.github/workflows/format.yml | 2 +-
.github/workflows/generate-doc-check.yml | 6 +-
.github/workflows/headers.yml | 4 +-
.github/workflows/link-validator.yml | 4 +-
.github/workflows/nightly-1.0-builds.yml | 12 +-
.github/workflows/nightly-1.1-builds.yml | 12 +-
.github/workflows/nightly-1.2-builds.yml | 12 +-
.github/workflows/nightly-1.3-builds.yml | 12 +-
.github/workflows/nightly-1.4-builds.yml | 12 +-
.github/workflows/nightly-1.5-builds.yml | 12 +-
.github/workflows/nightly-1.6-builds.yml | 12 +-
.github/workflows/nightly-1.7-builds.yml | 12 +-
.github/workflows/nightly-builds-aeron.yml | 4 +-
.github/workflows/nightly-builds.yml | 12 +-
.github/workflows/publish-1.0-docs.yml | 4 +-
.github/workflows/publish-1.0-nightly.yml | 4 +-
.github/workflows/publish-1.1-docs.yml | 4 +-
.github/workflows/publish-1.1-nightly.yml | 4 +-
.github/workflows/publish-1.2-docs.yml | 4 +-
.github/workflows/publish-1.2-nightly.yml | 4 +-
.github/workflows/publish-1.3-docs.yml | 4 +-
.github/workflows/publish-1.3-nightly.yml | 4 +-
.github/workflows/publish-1.4-docs.yml | 4 +-
.github/workflows/publish-1.4-nightly.yml | 4 +-
.github/workflows/publish-1.5-docs.yml | 4 +-
.github/workflows/publish-1.5-nightly.yml | 4 +-
.github/workflows/publish-1.6-docs.yml | 4 +-
.github/workflows/publish-1.6-nightly.yml | 4 +-
.github/workflows/publish-1.7-nightly.yml | 4 +-
.github/workflows/publish-2.0-docs.yml | 16 +-
.github/workflows/publish-nightly.yml | 4 +-
.github/workflows/stage-release-candidate.yml | 8 +-
.github/workflows/timing-tests.yml | 4 +-
.scala-steward.conf | 2 -
.scalafmt.conf | 12 +-
AGENTS.md | 2 +-
CONTRIBUTING.md | 2 +-
.../apache/pekko/actor/testkit/typed/Effect.scala | 18 +-
.../actor/testkit/typed/TestKitSettings.scala | 10 +-
.../testkit/typed/internal/ActorSystemStub.scala | 2 +-
.../typed/internal/LoggingTestKitImpl.scala | 10 +-
.../typed/internal/StubbedActorContext.scala | 4 +-
.../testkit/typed/internal/TestKitUtils.scala | 6 +-
.../testkit/typed/internal/TestProbeImpl.scala | 2 +-
.../actor/testkit/typed/javadsl/ActorTestKit.scala | 8 +-
.../testkit/typed/javadsl/BehaviorTestKit.scala | 2 +-
.../typed/javadsl/JUnit5TestKitBuilder.scala | 4 +-
.../typed/javadsl/JUnitJupiterTestKitBuilder.scala | 4 +-
.../testkit/typed/javadsl/LoggingTestKit.scala | 6 +-
.../actor/testkit/typed/javadsl/ManualTime.scala | 2 +-
.../typed/javadsl/SerializationTestKit.scala | 2 +-
.../actor/testkit/typed/javadsl/TestInbox.scala | 2 +-
.../typed/javadsl/TestKitJunitResource.scala | 2 +-
.../actor/testkit/typed/javadsl/TestProbe.scala | 8 +-
.../testkit/typed/scaladsl/ActorTestKit.scala | 8 +-
.../testkit/typed/scaladsl/LoggingTestKit.scala | 2 +-
.../actor/testkit/typed/scaladsl/ManualTime.scala | 4 +-
.../typed/scaladsl/ScalaTestWithActorTestKit.scala | 2 +-
.../typed/scaladsl/SerializationTestKit.scala | 2 +-
.../actor/testkit/typed/scaladsl/TestInbox.scala | 2 +-
.../actor/testkit/typed/scaladsl/TestProbe.scala | 4 +-
.../typed/javadsl/AsyncTestingExampleTest.java | 5 +-
.../typed/scaladsl/SyncTestingExampleSpec.scala | 4 +-
.../testkit/typed/scaladsl/ActorTestKitSpec.scala | 4 +-
.../typed/scaladsl/BehaviorTestKitSpec.scala | 6 +-
.../org/apache/pekko/util/LineNumberSpec.scala | 4 +-
.../org/apache/pekko/PekkoExceptionSpec.scala | 2 +-
.../actor/AbstractActorPreRestartFinalSpec.scala | 6 +-
.../org/apache/pekko/actor/ActorMailboxSpec.scala | 2 +-
.../org/apache/pekko/actor/DynamicAccessSpec.scala | 2 +-
.../org/apache/pekko/actor/ExtensionSpec.scala | 2 +-
.../pekko/actor/SupervisorHierarchySpec.scala | 4 +-
.../org/apache/pekko/actor/SupervisorSpec.scala | 26 +
.../apache/pekko/dispatch/MailboxConfigSpec.scala | 2 +-
.../pekko/io/UdpConnectedIntegrationSpec.scala | 2 +-
.../apache/pekko/io/dns/DockerBindDnsService.scala | 4 +-
.../org/apache/pekko/pattern/StatusReplySpec.scala | 2 +-
.../serialization/SerializationSetupSpec.scala | 2 +-
.../apache/pekko/serialization/SerializeSpec.scala | 12 +-
.../pekko/util/BoundedBlockingQueueSpec.scala | 2 +-
.../pekko/util/ByteStringInitializationSpec.scala | 2 +-
.../org/apache/pekko/util/ByteStringSpec.scala | 2 +-
.../apache/pekko/util/FrequencySketchSpec.scala | 42 ++
.../scala/org/apache/pekko/util/SWARUtilSpec.scala | 2 +-
.../org/apache/pekko/util/WildcardIndexSpec.scala | 6 +-
.../apache/pekko/typed/GracefulStopDocTest.java | 2 +
.../InteractionPatternsAskWithStatusTest.java | 2 +
.../jdocs/org/apache/pekko/typed/IntroTest.java | 10 +
.../org/apache/pekko/typed/LoggingDocExamples.java | 3 +
.../jdocs/org/apache/pekko/typed/OOIntroTest.java | 5 +
.../apache/pekko/typed/SpawnProtocolDocTest.java | 1 +
.../eventstream/EventStreamSuperClassDocTest.java | 1 +
.../pekko/typed/InteractionPatterns3Spec.scala | 22 +-
.../pekko/typed/InteractionPatternsSpec.scala | 4 +-
.../apache/pekko/typed/LoggingDocExamples.scala | 4 +-
.../apache/pekko/typed/StyleGuideDocExamples.scala | 2 +-
.../pekko/typed/extensions/ExtensionDocSpec.scala | 6 +-
.../org/apache/pekko/actor/typed/AskSpec.scala | 2 +-
.../apache/pekko/actor/typed/ExtensionsSpec.scala | 20 +-
.../LocalActorRefProviderLogMessagesSpec.scala | 8 +-
.../pekko/actor/typed/MailboxSelectorSpec.scala | 2 +-
.../apache/pekko/actor/typed/SupervisionSpec.scala | 6 +-
.../delivery/DurableProducerControllerSpec.scala | 4 +-
.../typed/delivery/DurableWorkPullingSpec.scala | 4 +-
.../delivery/ReliableDeliveryRandomSpec.scala | 4 +-
.../actor/typed/internal/ActorSystemSpec.scala | 2 +-
.../receptionist/LocalReceptionistSpec.scala | 2 +-
.../actor/typed/scaladsl/MailboxSelectorSpec.scala | 4 +-
.../typed/internal/receptionist/Platform.scala | 4 +-
.../org/apache/pekko/actor/typed/ActorRef.scala | 2 +-
.../pekko/actor/typed/ActorRefResolver.scala | 10 +-
.../pekko/actor/typed/BehaviorInterceptor.scala | 8 +-
.../org/apache/pekko/actor/typed/Extensions.scala | 10 +-
.../apache/pekko/actor/typed/SpawnProtocol.scala | 2 +-
.../actor/typed/delivery/ConsumerController.scala | 4 +-
.../typed/delivery/DurableProducerQueue.scala | 4 +-
.../actor/typed/delivery/ProducerController.scala | 4 +-
.../delivery/WorkPullingProducerController.scala | 4 +-
.../delivery/internal/ConsumerControllerImpl.scala | 18 +-
.../delivery/internal/ProducerControllerImpl.scala | 4 +-
.../WorkPullingProducerControllerImpl.scala | 2 +-
.../actor/typed/eventstream/EventStream.scala | 2 +-
.../actor/typed/internal/ActorContextImpl.scala | 14 +-
.../actor/typed/internal/ActorFlightRecorder.scala | 2 +-
.../pekko/actor/typed/internal/ActorRefImpl.scala | 4 +-
.../typed/internal/EventStreamExtension.scala | 4 +-
.../actor/typed/internal/ExtensionsImpl.scala | 14 +-
.../actor/typed/internal/InterceptorImpl.scala | 10 +-
.../pekko/actor/typed/internal/LoggerClass.scala | 10 +-
.../typed/internal/MiscMessageSerializer.scala | 4 +-
.../pekko/actor/typed/internal/PoisonPill.scala | 2 +-
.../pekko/actor/typed/internal/Supervision.scala | 18 +-
.../internal/WithMdcBehaviorInterceptor.scala | 4 +-
.../typed/internal/adapter/ActorAdapter.scala | 8 +-
.../internal/adapter/ActorContextAdapter.scala | 8 +-
.../typed/internal/adapter/ActorRefAdapter.scala | 4 +-
.../internal/adapter/ActorSystemAdapter.scala | 10 +-
.../typed/internal/adapter/PropsAdapter.scala | 2 +-
.../pekko/actor/typed/internal/jfr/Events.scala | 3 +-
.../internal/receptionist/LocalReceptionist.scala | 8 +-
.../internal/receptionist/ReceptionistImpl.scala | 2 +-
.../receptionist/ReceptionistMessages.scala | 6 +-
.../receptionist/ServiceKeySerializer.scala | 4 +-
.../typed/internal/routing/GroupRouterImpl.scala | 2 +-
.../typed/internal/routing/PoolRouterImpl.scala | 2 +-
.../pekko/actor/typed/javadsl/ActorContext.scala | 2 +-
.../apache/pekko/actor/typed/javadsl/Adapter.scala | 18 +-
.../actor/typed/javadsl/BehaviorBuilder.scala | 4 +-
.../pekko/actor/typed/javadsl/ReceiveBuilder.scala | 4 +-
.../actor/typed/receptionist/Receptionist.scala | 26 +-
.../pekko/actor/typed/scaladsl/ActorContext.scala | 2 +-
.../pekko/actor/typed/scaladsl/AskPattern.scala | 4 +-
.../actor/typed/scaladsl/adapter/package.scala | 8 +-
actor/src/main/resources/reference.conf | 2 +-
.../org/apache/pekko/util/ByteIterator.scala | 159 +++---
.../org/apache/pekko/actor/AbstractProps.scala | 10 +-
.../scala/org/apache/pekko/actor/ActorCell.scala | 2 +-
.../org/apache/pekko/actor/ActorRefProvider.scala | 6 +-
.../scala/org/apache/pekko/actor/ActorSystem.scala | 8 +-
.../apache/pekko/actor/CoordinatedShutdown.scala | 4 +-
.../scala/org/apache/pekko/actor/Deployer.scala | 2 +-
.../org/apache/pekko/actor/DynamicAccess.scala | 6 +-
.../scala/org/apache/pekko/actor/Extension.scala | 2 +-
.../main/scala/org/apache/pekko/actor/FSM.scala | 4 +-
.../org/apache/pekko/actor/FaultHandling.scala | 22 +-
.../apache/pekko/actor/IndirectActorProducer.scala | 16 +-
.../main/scala/org/apache/pekko/actor/Props.scala | 12 +-
.../pekko/actor/ReflectiveDynamicAccess.scala | 10 +-
.../main/scala/org/apache/pekko/actor/Stash.scala | 2 +-
.../pekko/actor/dungeon/ChildrenContainer.scala | 4 +-
.../org/apache/pekko/actor/dungeon/Dispatch.scala | 2 +-
.../pekko/actor/dungeon/TimerSchedulerImpl.scala | 2 +-
.../pekko/actor/setup/ActorSystemSetup.scala | 2 +-
.../apache/pekko/dispatch/CompletionStages.scala | 18 +-
.../dispatch/ForkJoinExecutorConfigurator.scala | 6 +-
.../org/apache/pekko/dispatch/Mailboxes.scala | 26 +-
.../apache/pekko/dispatch/ThreadPoolBuilder.scala | 8 +-
.../dispatch/VirtualizedExecutorService.scala | 10 +-
.../scala/org/apache/pekko/event/EventStream.scala | 14 +-
.../scala/org/apache/pekko/event/Logging.scala | 154 +++---
.../scala/org/apache/pekko/io/DnsProvider.scala | 4 +-
.../org/apache/pekko/io/SelectionHandler.scala | 6 +-
.../scala/org/apache/pekko/io/SimpleDnsCache.scala | 4 +-
.../main/scala/org/apache/pekko/japi/JavaAPI.scala | 4 +-
.../org/apache/pekko/pattern/CircuitBreaker.scala | 6 +-
.../pekko/pattern/CircuitBreakersRegistry.scala | 2 +-
.../scala/org/apache/pekko/pattern/Patterns.scala | 13 +-
.../org/apache/pekko/pattern/StatusReply.scala | 4 +-
.../internal/BackoffOnRestartSupervisor.scala | 2 +-
.../pekko/serialization/PrimitiveSerializers.scala | 10 +-
.../apache/pekko/serialization/Serialization.scala | 28 +-
.../pekko/serialization/SerializationSetup.scala | 6 +-
.../apache/pekko/serialization/Serializer.scala | 20 +-
.../apache/pekko/util/BoundedBlockingQueue.scala | 14 +-
.../scala/org/apache/pekko/util/BoxedType.scala | 4 +-
.../pekko/util/ClassLoaderObjectInputStream.scala | 2 +-
.../org/apache/pekko/util/FrequencySketch.scala | 14 +-
.../scala/org/apache/pekko/util/LineNumbers.scala | 4 +-
.../main/scala/org/apache/pekko/util/Reflect.scala | 20 +-
.../org/apache/pekko/util/TypedMultiMap.scala | 2 +-
.../pekko/actor/typed/TypedBenchmarkActors.scala | 2 +-
.../pekko/remote/artery/CodecBenchmark.scala | 2 +-
.../ActorGraphInterpreterBoundaryBenchmark.scala | 2 +-
.../stream/AsyncBoundaryThroughputBenchmark.scala | 123 +++++
.../pekko/stream/BroadcastHubBenchRunner.scala | 113 ++++
.../pekko/stream/BroadcastHubBenchmark.scala | 50 +-
.../org/apache/pekko/stream/FlowMapBenchmark.scala | 2 +-
.../stream/GraphStageConstructionBenchmark.scala | 15 +-
.../pekko/stream/MaterializerWiringBenchmark.scala | 132 +++++
.../pekko/stream/StageActorRefBenchmark.scala | 136 +++++
.../org/apache/pekko/stream/io/TlsBenchmark.scala | 3 +-
.../util/ByteStringParser_readNum_Benchmark.scala | 4 +-
build.sbt | 15 +-
.../protobuf/msg/ClusterMetricsMessages.java | 230 ++++----
.../cluster/metrics/ClusterMetricsCollector.scala | 4 +-
.../cluster/metrics/ClusterMetricsExtension.scala | 4 +-
.../pekko/cluster/metrics/MetricsCollector.scala | 2 +-
.../metrics/protobuf/NumberInputStream.scala | 2 +-
.../typed/internal/protobuf/ShardingMessages.java | 110 ++--
.../remove-old-passivation-strategy.excludes | 6 +-
.../sharding/typed/ClusterShardingQuery.scala | 8 +-
.../sharding/typed/ClusterShardingSettings.scala | 69 +--
.../typed/ReplicatedShardingExtension.scala | 4 +-
.../typed/ShardedDaemonProcessSettings.scala | 6 +-
.../delivery/ShardingConsumerController.scala | 4 +-
.../delivery/ShardingProducerController.scala | 4 +-
.../internal/ShardingConsumerControllerImpl.scala | 2 +-
.../internal/ShardingProducerControllerImpl.scala | 4 +-
.../typed/internal/ClusterShardingImpl.scala | 12 +-
.../internal/ReplicatedShardingExtensionImpl.scala | 2 +-
.../internal/ShardedDaemonProcessCoordinator.scala | 2 +-
.../typed/internal/ShardedDaemonProcessImpl.scala | 2 +-
.../typed/internal/ShardingSerializer.scala | 6 +-
.../typed/internal/testkit/TestEntityRefImpl.scala | 4 +-
.../sharding/typed/javadsl/ClusterSharding.scala | 2 +-
.../typed/javadsl/ShardedDaemonProcess.scala | 4 +-
.../sharding/typed/scaladsl/ClusterSharding.scala | 6 +-
.../typed/scaladsl/ShardedDaemonProcess.scala | 2 +-
.../typed/delivery/DeliveryThroughputSpec.scala | 2 +-
.../jdocs/delivery/PointToPointDocExample.java | 2 +
.../java/jdocs/delivery/ShardingDocExample.java | 2 +
.../java/jdocs/delivery/WorkPullingDocExample.java | 2 +
.../sharding/typed/AccountExampleDocTest.java | 8 +-
.../AccountExamplePersistenceProbeDocTest.java | 219 ++++----
.../typed/HelloWorldPersistentEntityExample.java | 3 +-
.../sharding/typed/ShardingCompileOnlyTest.java | 2 +
...urableStateStoreQueryUsageCompileOnlySpec.scala | 2 +-
.../ExternalShardAllocationCompileOnlySpec.scala | 2 +-
.../typed/HelloWorldPersistentEntityExample.scala | 2 +-
.../typed/ReplicatedShardingCompileOnlySpec.scala | 2 +-
.../pekko/cluster/sharding/FlightRecording.scala | 2 +-
...oinConfigCompatCheckerClusterShardingSpec.scala | 4 +-
.../sharding/typed/ReplicatedShardingSpec.scala | 2 +-
.../typed/delivery/DurableShardingSpec.scala | 8 +-
.../delivery/ReliableDeliveryShardingSpec.scala | 2 +-
.../internal/ShardedDaemonProcessIdSpec.scala | 1 +
.../scaladsl/ClusterShardingPersistenceSpec.scala | 2 +-
.../protobuf/msg/ClusterShardingMessages.java | 588 ++++++++++++---------
.../remove-old-passivation-strategy.excludes | 8 +-
cluster-sharding/src/main/resources/reference.conf | 6 -
.../pekko/cluster/sharding/ClusterSharding.scala | 66 +--
.../cluster/sharding/ClusterShardingSettings.scala | 80 +--
.../pekko/cluster/sharding/ShardCoordinator.scala | 10 +-
.../pekko/cluster/sharding/ShardRegion.scala | 28 +-
.../cluster/sharding/ShardingFlightRecorder.scala | 2 +-
.../cluster/sharding/internal/jfr/Events.scala | 3 +-
.../ClusterShardingCoordinatorRoleSpec.scala | 6 +-
.../sharding/MultiNodeClusterShardingConfig.scala | 2 +-
.../sharding/ClusterShardingSettingsSpec.scala | 11 -
.../sharding/ConcurrentStartupShardingSpec.scala | 2 +-
.../sharding/PersistentShardingMigrationSpec.scala | 2 +-
.../RememberEntitiesAndStartEntitySpec.scala | 3 +-
.../sharding/ShardRegionDataTypesSpec.scala | 116 ++++
.../cluster/sharding/ShardingQueriesSpec.scala | 6 +-
.../client/protobuf/msg/ClusterClientMessages.java | 28 +-
.../protobuf/msg/DistributedPubSubMessages.java | 244 +++++----
.../pekko/cluster/client/ClusterClient.scala | 2 +-
.../singleton/ClusterSingletonManager.scala | 10 +-
.../cluster/singleton/ClusterSingletonProxy.scala | 8 +-
.../typed/internal/protobuf/ClusterMessages.java | 46 +-
.../typed/internal/protobuf/ReliableDelivery.java | 190 ++++---
.../receptionist/ClusterReceptionistProtocol.scala | 2 +-
.../ddata/typed/internal/ReplicatorBehavior.scala | 16 +-
.../ddata/typed/javadsl/DistributedData.scala | 10 +-
.../typed/javadsl/ReplicatorMessageAdapter.scala | 8 +-
.../ddata/typed/javadsl/ReplicatorSettings.scala | 2 +-
.../ddata/typed/scaladsl/DistributedData.scala | 6 +-
.../typed/scaladsl/ReplicatorMessageAdapter.scala | 8 +-
.../ddata/typed/scaladsl/ReplicatorSettings.scala | 4 +-
.../org/apache/pekko/cluster/typed/Cluster.scala | 8 +-
.../pekko/cluster/typed/ClusterSingleton.scala | 16 +-
.../typed/internal/AdaptedClusterImpl.scala | 4 +-
.../internal/AdaptedClusterSingletonImpl.scala | 10 +-
.../internal/PekkoClusterTypedSerializer.scala | 8 +-
.../delivery/ReliableDeliverySerializer.scala | 26 +-
.../receptionist/ClusterReceptionist.scala | 20 +-
.../receptionist/ClusterReceptionistSettings.scala | 2 +-
.../typed/internal/receptionist/Registry.scala | 12 +-
.../cluster/typed/SingletonCompileOnlyTest.java | 1 +
.../cluster/typed/BasicClusterExampleSpec.scala | 10 +-
.../cluster/typed/DistributedPubSubExample.scala | 6 +-
.../pekko/cluster/typed/GroupRouterSpec.scala | 8 +-
.../cluster/protobuf/msg/ClusterMessages.java | 501 ++++++++++--------
.../scala/org/apache/pekko/cluster/Cluster.scala | 10 +-
.../org/apache/pekko/cluster/ClusterDaemon.scala | 4 +-
.../org/apache/pekko/cluster/ClusterEvent.scala | 4 +-
.../pekko/cluster/CrossDcClusterHeartbeat.scala | 8 +-
.../org/apache/pekko/cluster/MembershipState.scala | 3 +-
.../org/apache/pekko/cluster/Reachability.scala | 4 +-
.../apache/pekko/cluster/sbr/DowningStrategy.scala | 7 +-
.../cluster/SurviveNetworkInstabilitySpec.scala | 2 +-
.../cluster/JoinConfigCompatCheckerSpec.scala | 4 +-
.../pekko/cluster/ReachabilityPerfSpec.scala | 2 +-
.../lease/scaladsl/LeaseProvider.scala | 2 +-
.../apache/pekko/discovery/ServiceDiscovery.scala | 3 +-
.../pekko/discovery/dns/DnsDiscoverySpec.scala | 2 +-
.../ddata/protobuf/msg/ReplicatedDataMessages.java | 450 +++++++++-------
.../ddata/protobuf/msg/ReplicatorMessages.java | 557 +++++++++++--------
.../org/apache/pekko/cluster/ddata/GSet.scala | 8 +-
.../scala/org/apache/pekko/cluster/ddata/Key.scala | 4 +-
.../org/apache/pekko/cluster/ddata/LWWMap.scala | 2 +-
.../apache/pekko/cluster/ddata/LWWRegister.scala | 2 +-
.../org/apache/pekko/cluster/ddata/ORMap.scala | 38 +-
.../apache/pekko/cluster/ddata/ORMultiMap.scala | 2 +-
.../org/apache/pekko/cluster/ddata/ORSet.scala | 28 +-
.../apache/pekko/cluster/ddata/PNCounterMap.scala | 2 +-
.../apache/pekko/cluster/ddata/Replicator.scala | 16 +-
.../ddata/protobuf/ReplicatedDataSerializer.scala | 134 ++---
.../protobuf/ReplicatorMessageSerializer.scala | 56 +-
.../cluster/ddata/JepsenInspiredInsertSpec.scala | 16 +-
.../pekko/cluster/ddata/ReplicatorChaosSpec.scala | 6 +-
.../pekko/cluster/ddata/ReplicatorDeltaSpec.scala | 24 +-
.../pekko/cluster/ddata/ReplicatorGossipSpec.scala | 4 +-
.../cluster/ddata/ReplicatorORSetDeltaSpec.scala | 2 +-
.../pekko/cluster/ddata/ReplicatorSpec.scala | 10 +-
.../cluster/ddata/WildcardSubscribeSpec.scala | 26 +-
.../pekko/cluster/ddata/LocalConcurrencySpec.scala | 2 +-
.../apache/pekko/cluster/ddata/LotsOfDataBot.scala | 2 +-
.../ddata/ReplicatorWildcardSubscriptionSpec.scala | 12 +-
.../ddata/protobuf/msg/TwoPhaseSetMessages.java | 50 +-
.../docs/persistence/proto/FlightAppModels.java | 28 +-
docs/src/main/paradox/discovery/index.md | 2 +-
.../src/main/paradox/release-notes/releases-2.0.md | 13 +
docs/src/main/paradox/serialization-jackson.md | 2 +-
.../stream/operators/Source-or-Flow/alsoToAll.md | 2 +-
docs/src/main/paradox/stream/operators/index.md | 2 +-
docs/src/main/paradox/stream/stream-refs.md | 2 +-
docs/src/main/paradox/typed/cluster-sharding.md | 2 +-
docs/src/main/paradox/typed/cluster-singleton.md | 6 +-
docs/src/main/paradox/typed/distributed-data.md | 2 +-
.../src/main/paradox/typed/persistence-snapshot.md | 2 +-
docs/src/main/paradox/typed/persistence-testing.md | 2 +-
docs/src/main/paradox/typed/style-guide.md | 2 +-
docs/src/test/java/jdocs/actor/ActorDocTest.java | 17 +
.../jdocs/actor/ByteBufferSerializerDocTest.java | 1 +
.../jdocs/actor/DependencyInjectionDocTest.java | 2 +
.../test/java/jdocs/actor/SchedulerDocTest.java | 2 -
docs/src/test/java/jdocs/actor/fsm/Buncher.java | 1 +
.../actor/typed/CoordinatedActorShutdownTest.java | 1 +
.../singleton/ClusterSingletonSupervision.java | 1 +
.../java/jdocs/dispatcher/DispatcherDocTest.java | 3 +
.../src/test/java/jdocs/event/EventBusDocTest.java | 4 +
docs/src/test/java/jdocs/event/LoggingDocTest.java | 3 +
.../jdocs/extension/SettingsExtensionDocTest.java | 1 +
docs/src/test/java/jdocs/future/FutureDocTest.java | 92 ++--
.../test/java/jdocs/io/UdpConnectedDocTest.java | 1 -
docs/src/test/java/jdocs/io/japi/IODocTest.java | 3 +
.../persistence/testkit/PersistenceInitTest.java | 23 +-
.../routing/ConsistentHashingRouterDocTest.java | 2 +
.../java/jdocs/routing/CustomRouterDocTest.java | 1 -
.../src/test/java/jdocs/routing/RouterDocTest.java | 2 +
.../jdocs/serialization/SerializationDocTest.java | 2 +
.../java/jdocs/sharding/ClusterShardingTest.java | 12 +-
.../stream/operators/BroadcastDocExample.java | 1 +
.../stream/operators/MergeSequenceDocExample.java | 1 +
.../stream/operators/PartitionDocExample.java | 1 +
.../java/jdocs/stream/operators/SourceOrFlow.java | 13 +-
.../stream/operators/source/AsSubscriber.java | 2 +-
.../stream/operators/source/FromPublisher.java | 2 +-
.../tutorial_1/ActorHierarchyExperiments.java | 4 +
.../docs/actor/SharedMutableStateDocSpec.scala | 2 +-
.../scala/docs/ddata/DistributedDataDocSpec.scala | 10 +-
docs/src/test/scala/docs/ddata/ShoppingCart.scala | 4 +-
.../ddata/protobuf/TwoPhaseSetSerializer.scala | 4 +-
.../ddata/protobuf/TwoPhaseSetSerializer2.scala | 2 +-
.../src/test/scala/docs/event/LoggingDocSpec.scala | 2 +-
docs/src/test/scala/docs/io/EchoServer.scala | 2 +-
.../persistence/PersistenceSerializerDocSpec.scala | 4 +-
.../docs/serialization/SerializationDocSpec.scala | 2 +-
.../test/scala/docs/stream/GraphDSLDocSpec.scala | 4 +-
.../docs/stream/cookbook/RecipeAdhocSource.scala | 2 +-
.../stream/operators/JavaCollectorDocExample.scala | 2 +-
.../scala/docs/stream/operators/source/Zip.scala | 2 +-
.../docs/stream/operators/sourceorflow/Limit.scala | 2 +-
.../operators/sourceorflow/LimitWeighted.scala | 2 +-
.../testconductor/TestConductorProtocol.java | 150 +++---
.../apache/pekko/remote/testconductor/Player.scala | 7 +-
.../pekko/remote/testkit/MultiNodeSpec.scala | 6 +-
.../apache/pekko/osgi/ActorSystemActivator.scala | 4 +-
.../pekko/osgi/BundleDelegatingClassLoader.scala | 4 +-
.../org/apache/pekko/osgi/PojoSRTestSupport.scala | 2 +-
.../query/internal/protobuf/QueryMessages.java | 63 ++-
.../query/internal/QuerySerializer.scala | 4 +-
.../journal/leveldb/AllPersistenceIdsStage.scala | 2 +-
.../leveldb/EventsByPersistenceIdStage.scala | 2 +-
.../query/journal/leveldb/EventsByTagStage.scala | 2 +-
.../persistence/query/typed/EventEnvelope.scala | 4 +-
.../persistence/serialization/SerializerSpec.scala | 4 +-
.../pekko/persistence/journal/JournalSpec.scala | 50 ++
.../persistence/testkit/SnapshotStorage.scala | 3 -
.../internal/EventSourcedBehaviorTestKitImpl.scala | 6 +-
.../testkit/internal/PersistenceProbeImpl.scala | 10 +-
.../SnapshotStorageEmulatorExtension.scala | 2 +-
.../javadsl/EventSourcedBehaviorTestKit.scala | 4 +-
.../testkit/javadsl/PersistenceProbeBehavior.scala | 3 +-
.../testkit/javadsl/PersistenceTestKit.scala | 2 +-
.../testkit/javadsl/SnapshotTestKit.scala | 2 +-
.../scaladsl/PersistenceTestKitReadJournal.scala | 1 +
.../scaladsl/EventSourcedBehaviorTestKit.scala | 4 +-
.../testkit/scaladsl/PersistenceTestKit.scala | 2 +-
.../persistence/testkit/scaladsl/TestOps.scala | 10 +-
.../javadsl/RuntimeDurableStateStoreTest.java | 160 ++++++
.../ReplicatedEventSourcingCompileOnlySpec.scala | 4 +-
.../scaladsl/EventSourcedBehaviorReplySpec.scala | 8 +-
...urcedBehaviorRetentionOnlyOneSnapshotSpec.scala | 7 +-
.../typed/scaladsl/EventSourcedBehaviorSpec.scala | 16 +-
.../scaladsl/EventSourcedBehaviorStashSpec.scala | 12 +-
.../scaladsl/EventSourcedBehaviorWatchSpec.scala | 4 +-
.../scaladsl/DurableStateBehaviorReplySpec.scala | 6 +-
.../DurableStateBehaviorStashOverflowSpec.scala | 4 +-
.../scaladsl/RuntimeDurableStateStoreSpec.scala | 100 ++++
.../serialization/ReplicatedEventSourcing.java | 262 +++++----
.../durablestate-runtime-config.excludes | 4 +-
.../pekko/persistence/typed/crdt/ORSet.scala | 2 +-
.../typed/delivery/EventSourcedProducerQueue.scala | 8 +-
.../typed/internal/EventSourcedBehaviorImpl.scala | 8 +-
.../typed/internal/EventSourcedSettings.scala | 4 +-
.../typed/internal/ExternalInteractions.scala | 8 +-
.../typed/internal/ReplayingEvents.scala | 8 +-
.../typed/internal/ReplayingSnapshot.scala | 4 +-
.../typed/internal/RequestingRecoveryPermit.scala | 2 +-
.../pekko/persistence/typed/internal/Running.scala | 14 +-
.../typed/javadsl/EventSourcedBehavior.scala | 7 +-
.../typed/javadsl/PersistentFSMMigration.scala | 2 +-
.../typed/scaladsl/EventSourcedBehavior.scala | 14 +-
.../typed/scaladsl/PersistentFSMMigration.scala | 2 +-
.../ReplicatedEventSourcingSerializer.scala | 28 +-
.../typed/state/internal/BehaviorSetup.scala | 6 +-
.../state/internal/DurableStateBehaviorImpl.scala | 18 +-
.../state/internal/DurableStateSettings.scala | 36 +-
.../internal/DurableStateStoreInteractions.scala | 2 +-
.../typed/state/internal/Recovering.scala | 6 +-
.../state/internal/RequestingRecoveryPermit.scala | 2 +-
.../persistence/typed/state/internal/Running.scala | 12 +-
.../typed/state/javadsl/DurableStateBehavior.scala | 23 +-
.../state/scaladsl/DurableStateBehavior.scala | 22 +-
.../typed/BasicPersistentBehaviorTest.java | 11 +
.../typed/DurableStatePersistentBehaviorTest.java | 4 +
...DurableStatePersistentBehaviorCompileOnly.scala | 24 +-
.../typed/StashingWhenSnapshottingSpec.scala | 2 +-
.../typed/internal/StashStateSpec.scala | 2 +-
.../scaladsl/PersistentActorCompileOnlyTest.scala | 2 +-
.../persistence/serialization/MessageFormats.java | 160 +++---
.../org/apache/pekko/persistence/TraitOrder.scala | 2 +-
.../org/apache/pekko/persistence/TraitOrder.scala | 2 +-
.../org/apache/pekko/persistence/Persistence.scala | 6 +-
.../pekko/persistence/PersistencePlugin.scala | 6 +-
.../pekko/persistence/journal/EventAdapters.scala | 21 +-
.../journal/PersistencePluginProxy.scala | 2 +-
.../serialization/MessageSerializer.scala | 2 +-
.../serialization/SnapshotSerializer.scala | 2 +-
.../state/DurableStateStoreRegistry.scala | 47 +-
.../persistence/AtLeastOnceDeliverySpec.scala | 2 +-
.../pekko/persistence/PersistentActorSpec.scala | 2 +-
.../SnapshotRecoveryWithEmptyJournalSpec.scala | 2 +-
.../persistence/SnapshotSerializationSpec.scala | 2 +-
.../apache/pekko/persistence/SnapshotSpec.scala | 2 +-
.../AsyncWriteJournalResponseOrderSpec.scala | 4 +-
.../SnapshotSerializerMigrationAkkaSpec.scala | 8 +-
.../SnapshotSerializerNoMigrationSpec.scala | 4 +-
.../serialization/SnapshotSerializerSpec.scala | 12 +-
.../exception/DurableStateExceptionsSpec.scala | 2 +-
project/AddLogTimestamps.scala | 2 +-
project/CopyrightHeaderForBoilerplate.scala | 2 +-
project/CopyrightHeaderForBuild.scala | 2 +-
...ForJdk9.scala => CopyrightHeaderForJdk21.scala} | 8 +-
project/CopyrightHeaderForProtobuf.scala | 2 +-
project/Dependencies.scala | 20 +-
project/JavaFormatter.scala | 2 +-
project/{Jdk9.scala => Jdk21.scala} | 38 +-
project/MultiNode.scala | 2 +-
project/PekkoBuild.scala | 9 +-
project/PekkoDevelocityPlugin.scala | 10 +-
project/ProjectFileIgnoreSupport.scala | 4 +-
project/Protobuf.scala | 2 +-
project/SbtMultiJvmPlugin.scala | 4 +-
project/ScalaFixExtraRulesPlugin.scala | 2 +-
...k9Plugin.scala => ScalaFixForJdk21Plugin.scala} | 12 +-
project/ScalafixForMultiNodePlugin.scala | 4 +-
project/ScalafixIgnoreFilePlugin.scala | 4 +-
project/StreamOperatorsIndexGenerator.scala | 2 +-
project/TestExtras.scala | 14 +-
project/ValidatePullRequest.scala | 2 +-
project/VersionGenerator.scala | 2 +-
project/build.properties | 2 +-
project/plugins.sbt | 6 +-
.../pekko/remote/artery/protobuf/TestMessages.java | 50 +-
.../apache/pekko/remote/ArteryControlFormats.java | 236 +++++----
.../org/apache/pekko/remote/ContainerFormats.java | 272 ++++++----
.../apache/pekko/remote/SystemMessageFormats.java | 120 +++--
.../java/org/apache/pekko/remote/WireFormats.java | 444 +++++++++-------
.../future-lazy-vals.excludes | 6 +-
remote/src/main/resources/reference.conf | 2 +-
.../scala/org/apache/pekko/remote/Endpoint.scala | 2 +-
.../org/apache/pekko/remote/RemoteDaemon.scala | 2 +-
.../pekko/remote/RemoteMetricsExtension.scala | 2 +-
.../pekko/remote/artery/ArteryTransport.scala | 4 +-
.../org/apache/pekko/remote/artery/Handshake.scala | 2 +-
.../pekko/remote/artery/ImmutableLongMap.scala | 2 +-
.../pekko/remote/artery/RemoteInstrument.scala | 2 +-
.../remote/artery/RemotingFlightRecorder.scala | 2 +-
.../remote/artery/SystemMessageDelivery.scala | 4 +-
.../artery/aeron/ArteryAeronUdpTransport.scala | 4 +-
.../remote/artery/compress/CompressionTable.scala | 2 +-
.../pekko/remote/artery/tcp/ssl/X509Readers.scala | 2 +-
.../serialization/DaemonMsgCreateSerializer.scala | 2 +-
.../serialization/MessageContainerSerializer.scala | 2 +-
.../serialization/MiscMessageSerializer.scala | 14 +-
.../remote/serialization/ProtobufSerializer.scala | 16 +-
.../serialization/SystemMessageSerializer.scala | 2 +-
.../org/apache/pekko/remote/ProtobufProtocol.java | 28 +-
.../remote/protobuf/v3/ProtobufProtocolV3.java | 28 +-
.../org/apache/pekko/remote/DaemonicSpec.scala | 7 +-
.../RemoteInstrumentsSerializationSpec.scala | 8 +-
.../remote/artery/RemoteSendConsistencySpec.scala | 4 +-
.../compress/CompressionIntegrationSpec.scala | 48 ++
.../ssl/RotatingKeysSSLEngineProviderSpec.scala | 3 +-
.../apache/pekko/remote/classic/RemotingSpec.scala | 13 +-
...reateSerializerAllowJavaSerializationSpec.scala | 4 +-
.../serialization/jackson/JacksonModule.scala | 14 +-
.../serialization/jackson/JacksonSerializer.scala | 24 +-
.../serialization/jackson/StreamRefModule.scala | 24 +-
.../jackson/TypedActorRefModule.scala | 12 +-
.../serialization/jackson3/JacksonModule.scala | 16 +-
.../jackson3/JacksonObjectMapperProvider.scala | 18 +-
.../serialization/jackson3/JacksonSerializer.scala | 27 +-
.../serialization/jackson3/StreamRefModule.scala | 24 +-
.../jackson3/TypedActorRefModule.scala | 12 +-
.../org/apache/pekko/event/slf4j/Slf4jLogger.scala | 18 +-
.../pekko/stream/testkit/StreamTestKit.scala | 8 +-
.../impl/fusing/GraphInterpreterSpecKit.scala | 30 +-
.../apache/pekko/stream/testkit/ChainSetup.scala | 6 +-
.../apache/pekko/stream/testkit/ScriptedTest.scala | 2 +-
.../apache/pekko/stream/testkit/StreamSpec.scala | 2 +-
.../pekko/stream/testkit/TwoStreamsSetup.scala | 2 +-
.../tck/FlatMapConcatDoubleSubscriberTest.scala | 2 +-
.../tck/PekkoIdentityProcessorVerification.scala | 2 +-
.../org/apache/pekko/stream/javadsl/TcpTest.java | 1 -
.../apache/pekko/stream/DslConsistencySpec.scala | 40 +-
.../pekko/stream/DslFactoriesConsistencySpec.scala | 46 +-
.../stream/impl/FanoutPublisherBehaviorSpec.scala | 6 +-
.../apache/pekko/stream/impl/FixedBufferSpec.scala | 16 +-
.../pekko/stream/impl/TraversalBuilderSpec.scala | 6 +-
.../impl/fusing/ActorGraphInterpreterSpec.scala | 4 +-
.../org/apache/pekko/stream/io/FileSinkSpec.scala | 2 +-
.../apache/pekko/stream/io/FileSourceSpec.scala | 2 +-
.../stream/io/TlsGraphStageEdgeCasesSpec.scala | 7 +-
.../io/compression/DeflateAutoFlushSpec.scala | 4 +-
.../stream/io/compression/GzipAutoFlushSpec.scala | 4 +-
.../scaladsl/CoupledTerminationFlowSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowCompileSpec.scala | 32 +-
.../pekko/stream/scaladsl/FlowConcatAllSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowConcatSpec.scala | 14 +-
.../pekko/stream/scaladsl/FlowGroupBySpec.scala | 14 +-
.../pekko/stream/scaladsl/FlowOnCompleteSpec.scala | 2 +-
.../stream/scaladsl/FlowPrefixAndTailSpec.scala | 12 +-
.../pekko/stream/scaladsl/FlowScanAsyncSpec.scala | 2 +-
.../apache/pekko/stream/scaladsl/FlowSpec.scala | 26 +-
.../pekko/stream/scaladsl/FlowSplitAfterSpec.scala | 6 +-
.../pekko/stream/scaladsl/FlowSplitWhenSpec.scala | 6 +-
.../pekko/stream/scaladsl/FlowTakeSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphConcatSpec.scala | 2 +-
.../stream/scaladsl/GraphMergeLatestSpec.scala | 2 +-
.../stream/scaladsl/GraphMergePreferredSpec.scala | 2 +-
.../scaladsl/GraphMergePrioritizedSpec.scala | 2 +-
.../stream/scaladsl/GraphMergeSequenceSpec.scala | 2 +-
.../stream/scaladsl/GraphMergeSortedSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphMergeSpec.scala | 2 +-
.../stream/scaladsl/GraphOpsIntegrationSpec.scala | 6 +-
.../pekko/stream/scaladsl/GraphUnzipWithSpec.scala | 8 +-
.../stream/scaladsl/GraphZipLatestWithSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphZipNSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphZipSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphZipWithNSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphZipWithSpec.scala | 2 +-
.../org/apache/pekko/stream/scaladsl/HubSpec.scala | 45 ++
.../apache/pekko/stream/scaladsl/RestartSpec.scala | 6 +-
.../apache/pekko/stream/scaladsl/SinkSpec.scala | 3 +-
.../pekko/stream/scaladsl/StageActorRefSpec.scala | 120 ++++-
.../SubstreamSubscriptionTimeoutSpec.scala | 6 +-
.../pekko/stream/MapAsyncPartitionedSpec.scala | 2 +-
.../stream/typed/ActorSourceSinkExample.scala | 8 +-
.../org/apache/pekko/stream/StreamRefMessages.java | 174 +++---
.../remove-dead-actorprocessor.excludes} | 14 +-
stream/src/main/resources/reference.conf | 7 +
.../scala/org/apache/pekko/stream/FanInShape.scala | 12 +-
.../org/apache/pekko/stream/FanOutShape.scala | 12 +-
.../main/scala/org/apache/pekko/stream/Shape.scala | 50 +-
.../apache/pekko/stream/impl/ActorProcessor.scala | 105 +---
.../apache/pekko/stream/impl/ActorPublisher.scala | 12 +-
.../stream/impl/ActorRefBackpressureSource.scala | 2 +-
.../pekko/stream/impl/ActorRefSinkStage.scala | 2 +-
.../apache/pekko/stream/impl/ActorRefSource.scala | 2 +-
.../pekko/stream/impl/CompletedPublishers.scala | 6 +-
.../stream/impl/ExposedPublisherReceive.scala | 43 --
.../stream/impl/FanoutPublisherBridgeStage.scala | 16 +-
.../stream/impl/JavaFlowAndRsConverters.scala | 8 +-
.../pekko/stream/impl/JavaStreamConcat.scala | 4 +-
.../impl/PhasedFusingActorMaterializer.scala | 84 ++-
.../org/apache/pekko/stream/impl/QueueSource.scala | 2 +-
.../scala/org/apache/pekko/stream/impl/Sinks.scala | 4 +-
.../apache/pekko/stream/impl/StreamLayout.scala | 32 +-
.../stream/impl/StreamSubscriptionTimeout.scala | 12 +-
.../pekko/stream/impl/SubscriberManagement.scala | 8 +-
.../pekko/stream/impl/TraversalBuilder.scala | 30 +-
.../stream/impl/fusing/ActorGraphInterpreter.scala | 2 +-
.../pekko/stream/impl/fusing/FlattenConcat.scala | 4 +-
.../pekko/stream/impl/fusing/GraphStages.scala | 4 +-
.../pekko/stream/impl/fusing/InflightSources.scala | 4 +-
.../pekko/stream/impl/fusing/IteratorSource.scala | 2 +-
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 10 +-
.../pekko/stream/impl/fusing/StreamOfStreams.scala | 14 +-
.../pekko/stream/impl/io/InputStreamSource.scala | 2 +-
.../stream/impl/io/OutputStreamGraphStage.scala | 2 +-
.../org/apache/pekko/stream/impl/io/TLSActor.scala | 20 +-
.../pekko/stream/impl/streamref/SinkRefImpl.scala | 2 +-
.../stream/impl/streamref/SourceRefImpl.scala | 4 +-
.../org/apache/pekko/stream/javadsl/Flow.scala | 101 ++--
.../pekko/stream/javadsl/FlowWithContext.scala | 2 +-
.../org/apache/pekko/stream/javadsl/Graph.scala | 30 +-
.../apache/pekko/stream/javadsl/RestartFlow.scala | 4 +-
.../apache/pekko/stream/javadsl/RestartSink.scala | 2 +-
.../pekko/stream/javadsl/RestartSource.scala | 4 +-
.../org/apache/pekko/stream/javadsl/Sink.scala | 13 +-
.../org/apache/pekko/stream/javadsl/Source.scala | 106 ++--
.../pekko/stream/javadsl/SourceWithContext.scala | 2 +-
.../pekko/stream/javadsl/StreamConverters.scala | 4 +-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 78 +--
.../apache/pekko/stream/javadsl/SubSource.scala | 78 +--
.../org/apache/pekko/stream/javadsl/Tcp.scala | 2 +-
.../org/apache/pekko/stream/javadsl/package.scala | 2 +-
.../org/apache/pekko/stream/scaladsl/Flow.scala | 48 +-
.../pekko/stream/scaladsl/FlowWithContext.scala | 8 +-
.../pekko/stream/scaladsl/FlowWithContextOps.scala | 8 +-
.../org/apache/pekko/stream/scaladsl/Graph.scala | 102 ++--
.../org/apache/pekko/stream/scaladsl/Hub.scala | 72 ++-
.../pekko/stream/scaladsl/JavaFlowSupport.scala | 2 +-
.../apache/pekko/stream/scaladsl/RestartFlow.scala | 12 +-
.../apache/pekko/stream/scaladsl/RestartSink.scala | 4 +-
.../pekko/stream/scaladsl/RestartSource.scala | 6 +-
.../org/apache/pekko/stream/scaladsl/Sink.scala | 6 +-
.../org/apache/pekko/stream/scaladsl/Source.scala | 10 +-
.../pekko/stream/scaladsl/SourceWithContext.scala | 8 +-
.../pekko/stream/scaladsl/StreamConverters.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/TLS.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/Tcp.scala | 6 +-
.../stream/serialization/StreamRefSerializer.scala | 18 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 278 ++++++++--
.../apache/pekko/stream/stage/StageLogging.scala | 2 +-
.../pekko/testkit/CallingThreadDispatcher.scala | 2 +-
.../apache/pekko/testkit/TestEventListener.scala | 8 +-
.../apache/pekko/testkit/TestJavaSerializer.scala | 2 +-
.../scala/org/apache/pekko/testkit/TestKit.scala | 18 +-
.../org/apache/pekko/testkit/TestKitUtils.scala | 2 +-
.../apache/pekko/testkit/javadsl/EventFilter.scala | 10 +-
.../org/apache/pekko/testkit/javadsl/TestKit.scala | 4 +-
.../scala/org/apache/pekko/testkit/PekkoSpec.scala | 8 +-
.../org/apache/pekko/testkit/PekkoSpecSpec.scala | 2 +-
.../apache/pekko/testkit/TestActorRefSpec.scala | 2 +-
.../metrics/reporter/PekkoConsoleReporter.scala | 6 +-
683 files changed, 7461 insertions(+), 5053 deletions(-)
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/AsyncBoundaryThroughputBenchmark.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/BroadcastHubBenchRunner.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/MaterializerWiringBenchmark.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/StageActorRefBenchmark.scala
copy
cluster-tools/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes
=>
cluster-sharding-typed/src/main/mima-filters/2.0.x.backwards.excludes/remove-old-passivation-strategy.excludes
(80%)
copy
stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-gunzip.excludes =>
cluster-sharding/src/main/mima-filters/2.0.x.backwards.excludes/remove-old-passivation-strategy.excludes
(76%)
create mode 100644
cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ShardRegionDataTypesSpec.scala
create mode 100644
persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/state/javadsl/RuntimeDurableStateStoreTest.java
create mode 100644
persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/RuntimeDurableStateStoreSpec.scala
copy
stream/src/main/mima-filters/1.0.x.backwards.excludes/pr-1374-boundedsourcequeue-iscompleted-classes.backwards.excludes
=>
persistence-typed/src/main/mima-filters/2.0.x.backwards.excludes/durablestate-runtime-config.excludes
(84%)
rename project/{CopyrightHeaderForJdk9.scala => CopyrightHeaderForJdk21.scala}
(82%)
rename project/{Jdk9.scala => Jdk21.scala} (63%)
rename project/{ScalaFixForJdk9Plugin.scala => ScalaFixForJdk21Plugin.scala}
(70%)
copy
actor-testkit-typed/src/main/mima-filters/2.0.x.backwards.excludes/renamed-methods.excludes
=>
remote/src/main/mima-filters/2.0.x.backwards.excludes/future-lazy-vals.excludes
(76%)
copy
stream/src/main/mima-filters/{1.0.x.backwards.excludes/28324-jdk9-specific-classes.backwards.excludes
=> 2.0.x.backwards.excludes/remove-dead-actorprocessor.excludes} (63%)
delete mode 100644
stream/src/main/scala/org/apache/pekko/stream/impl/ExposedPublisherReceive.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
