This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
from c76f814815 onDownstreamFinish() has been removed (#2627)
new 285793b42a Update scalafmt-core to 3.10.4
new 63212bde59 Reformat with scalafmt 3.10.4
new e087c98871 Add 'Reformat with scalafmt 3.10.4' to
.git-blame-ignore-revs
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.git-blame-ignore-revs | 3 ++
.scalafmt.conf | 2 +-
.../org/apache/pekko/actor/ActorSystemSpec.scala | 11 +++--
.../pekko/actor/CoordinatedShutdownSpec.scala | 9 ++--
.../apache/pekko/actor/ReceiveTimeoutSpec.scala | 3 +-
.../org/apache/pekko/actor/SchedulerSpec.scala | 9 ++--
.../pekko/actor/SupervisorHierarchySpec.scala | 3 +-
.../actor/dispatch/BalancingDispatcherSpec.scala | 3 +-
.../scala/org/apache/pekko/pattern/AskSpec.scala | 4 +-
.../apache/pekko/actor/typed/SupervisionSpec.scala | 15 ++++--
.../actor/typed/internal/ActorSystemSpec.scala | 3 +-
.../typed/delivery/DurableProducerQueue.scala | 6 ++-
.../delivery/internal/ProducerControllerImpl.scala | 3 +-
.../pekko/actor/typed/internal/Supervision.scala | 3 +-
.../scala/org/apache/pekko/actor/ActorPath.scala | 9 +++-
.../scala/org/apache/pekko/actor/ActorSystem.scala | 9 ++--
.../pekko/actor/LightArrayRevolverScheduler.scala | 11 +++--
.../main/scala/org/apache/pekko/actor/Stash.scala | 5 +-
.../org/apache/pekko/dispatch/Mailboxes.scala | 11 ++---
.../apache/pekko/dispatch/ThreadPoolBuilder.scala | 17 ++-----
.../scala/org/apache/pekko/event/EventStream.scala | 3 +-
.../org/apache/pekko/event/LoggingReceive.scala | 5 +-
.../pekko/io/dns/internal/TcpDnsClient.scala | 3 +-
.../org/apache/pekko/pattern/CircuitBreaker.scala | 3 +-
.../pekko/pattern/CircuitBreakersRegistry.scala | 7 +--
.../scala/org/apache/pekko/pattern/Patterns.scala | 8 +--
.../internal/BackoffOnRestartSupervisor.scala | 8 +--
.../pattern/internal/BackoffOnStopSupervisor.scala | 8 +--
.../org/apache/pekko/routing/ConsistentHash.scala | 6 ++-
.../org/apache/pekko/util/FrequencySketch.scala | 9 ++--
.../scala/org/apache/pekko/util/SWARUtil.scala | 3 +-
.../typed/delivery/ReliableDeliveryBenchmark.scala | 5 +-
.../apache/pekko/io/dns/IdGeneratorBanchmark.scala | 11 +----
build.sbt | 8 +--
.../internal/ShardingProducerControllerImpl.scala | 9 ++--
.../cluster/sharding/typed/internal/Murmur2.scala | 5 +-
.../internal/ReplicatedShardingExtensionImpl.scala | 3 +-
.../typed/delivery/DeliveryThroughputSpec.scala | 10 ++--
.../cluster/sharding/ClusterShardingSettings.scala | 3 +-
.../pekko/cluster/sharding/ShardCoordinator.scala | 7 ++-
.../pekko/cluster/sharding/ShardRegion.scala | 12 ++---
.../internal/LeastShardAllocationStrategy.scala | 5 +-
.../ClusterShardingMessageSerializer.scala | 3 +-
.../RandomizedBrainResolverIntegrationSpec.scala | 13 +++--
.../sharding/MultiDcClusterShardingSpec.scala | 3 +-
.../sharding/MultiNodeClusterShardingConfig.scala | 3 +-
.../JoinConfigCompatCheckShardingSpec.scala | 3 +-
...eastShardAllocationStrategyRandomizedSpec.scala | 6 +--
.../cluster/pubsub/DistributedPubSubMediator.scala | 7 +--
.../ddata/typed/internal/ReplicatorBehavior.scala | 57 ++++++++++------------
.../pekko/cluster/typed/ClusterSingleton.scala | 3 +-
.../receptionist/ClusterReceptionist.scala | 4 +-
.../delivery/ReliableDeliverySerializerSpec.scala | 6 ++-
.../org/apache/pekko/cluster/ClusterDaemon.scala | 9 ++--
.../org/apache/pekko/cluster/ClusterEvent.scala | 3 +-
.../org/apache/pekko/cluster/MembershipState.scala | 3 +-
.../cluster/routing/ClusterRouterConfig.scala | 3 +-
.../ClusterAccrualFailureDetectorSpec.scala | 3 +-
.../pekko/cluster/ClusterDeathWatchSpec.scala | 3 +-
.../apache/pekko/cluster/JoinInProgressSpec.scala | 3 +-
.../apache/pekko/cluster/LeaderLeavingSpec.scala | 3 +-
.../cluster/MembershipChangeListenerUpSpec.scala | 6 ++-
.../pekko/cluster/MinMembersBeforeUpSpec.scala | 6 ++-
.../pekko/cluster/MultiDcSunnyWeatherSpec.scala | 5 +-
.../apache/pekko/cluster/NodeMembershipSpec.scala | 6 ++-
.../org/apache/pekko/cluster/SplitBrainSpec.scala | 3 +-
.../org/apache/pekko/cluster/StressSpec.scala | 14 +++---
.../cluster/ClusterHeartbeatSenderStateSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckerSpec.scala | 27 ++++++----
.../pekko/cluster/ReachabilityPerfSpec.scala | 15 +++---
.../pekko/cluster/StartupWithOneThreadSpec.scala | 6 ++-
.../apache/pekko/cluster/VectorClockPerfSpec.scala | 12 ++---
.../pekko/cluster/sbr/SplitBrainResolverSpec.scala | 21 +++++---
.../org/apache/pekko/cluster/ddata/ORMap.scala | 14 +++---
.../apache/pekko/cluster/ddata/Replicator.scala | 3 +-
.../docs/actor/io/dns/DnsCompileOnlyDocSpec.scala | 12 ++---
.../test/scala/typed/tutorial_5/DeviceGroup.scala | 6 +--
.../pekko/remote/testconductor/Conductor.scala | 13 +----
.../remote/testconductor/RemoteConnection.scala | 5 +-
.../leveldb/EventsByPersistenceIdStage.scala | 3 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 3 +-
.../persistence/scalatest/OptionalTests.scala | 5 +-
.../javadsl/PersistenceTestKitReadJournal.scala | 6 +--
.../scaladsl/PersistenceTestKitReadJournal.scala | 5 +-
.../PersistenceTestKitDurableStateStore.scala | 7 +--
.../scaladsl/EventSourcedBehaviorTestKitSpec.scala | 3 +-
.../testkit/scaladsl/ScalaDslUtils.scala | 10 +---
.../typed/ReplicatedAuctionExampleSpec.scala | 6 ++-
.../persistence/typed/internal/BehaviorSetup.scala | 3 +-
.../pekko/persistence/typed/internal/Running.scala | 16 ++----
.../persistence/typed/ManyRecoveriesSpec.scala | 3 +-
.../journal/PersistencePluginProxy.scala | 11 +----
.../persistence/journal/inmem/InmemJournal.scala | 9 ++--
.../persistence/AtLeastOnceDeliverySpec.scala | 6 ++-
project/Doc.scala | 3 +-
project/Paradox.scala | 9 ++--
project/PekkoBuild.scala | 20 +++++---
project/PekkoDevelocityPlugin.scala | 5 +-
project/PekkoDisciplinePlugin.scala | 53 ++++++++++----------
project/SbtMultiJvmPlugin.scala | 3 +-
project/StreamOperatorsIndexGenerator.scala | 3 +-
project/TestExtras.scala | 9 ++--
.../pekko/remote/routing/RemoteRandomSpec.scala | 3 +-
.../remote/routing/RemoteScatterGatherSpec.scala | 3 +-
.../scala/org/apache/pekko/remote/Endpoint.scala | 8 ++-
.../org/apache/pekko/remote/RemoteDaemon.scala | 13 +----
.../pekko/remote/artery/ArteryTransport.scala | 4 +-
.../apache/pekko/remote/artery/Association.scala | 3 +-
.../pekko/remote/artery/EnvelopeBufferPool.scala | 6 +--
.../pekko/remote/artery/MessageDispatcher.scala | 3 +-
.../pekko/remote/artery/aeron/AeronSink.scala | 3 +-
.../artery/aeron/ArteryAeronUdpTransport.scala | 11 ++---
.../remote/artery/compress/CompressionTable.scala | 3 +-
.../remote/artery/tcp/ArteryTcpTransport.scala | 11 ++---
.../transport/AbstractTransportAdapter.scala | 3 +-
.../transport/ThrottlerTransportAdapter.scala | 6 +--
.../remote/transport/netty/NettyTransport.scala | 14 +-----
.../pekko/remote/AccrualFailureDetectorSpec.scala | 7 ++-
.../pekko/remote/DeadlineFailureDetectorSpec.scala | 3 +-
.../pekko/remote/artery/ImmutableLongMapSpec.scala | 9 ++--
.../remote/artery/OutboundIdleShutdownSpec.scala | 3 +-
.../remote/artery/RemoteActorSelectionSpec.scala | 11 +----
.../pekko/remote/artery/RemoteWatcherSpec.scala | 3 +-
.../pekko/remote/artery/tcp/TcpFramingSpec.scala | 4 +-
.../pekko/remote/classic/RemoteWatcherSpec.scala | 3 +-
.../classic/transport/PekkoProtocolSpec.scala | 5 +-
.../ArteryMessageSerializerSpec.scala | 4 +-
.../jackson/JacksonObjectMapperProvider.scala | 23 ++-------
.../jackson3/JacksonObjectMapperProvider.scala | 13 +----
.../jackson3/JacksonSerializerSpec.scala | 6 +--
.../pekko/stream/testkit/StreamTestKit.scala | 6 +--
.../impl/fusing/GraphInterpreterSpecKit.scala | 5 +-
.../apache/pekko/stream/DslConsistencySpec.scala | 6 ++-
.../pekko/stream/DslFactoriesConsistencySpec.scala | 9 ++--
.../stream/impl/LinearTraversalBuilderSpec.scala | 3 +-
.../pekko/stream/impl/fusing/InterpreterSpec.scala | 3 +-
.../impl/fusing/LifecycleInterpreterSpec.scala | 6 ++-
.../pekko/stream/io/ByteStringParserSpec.scala | 3 +-
.../pekko/stream/io/InputStreamSourceSpec.scala | 6 +--
.../stream/scaladsl/CancellationStrategySpec.scala | 3 +-
.../stream/scaladsl/FlowFlatMapPrefixSpec.scala | 11 +----
.../stream/scaladsl/FlowGroupedWithinSpec.scala | 3 +-
.../pekko/stream/scaladsl/FlowIteratorSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowOrElseSpec.scala | 3 +-
.../apache/pekko/stream/scaladsl/RestartSpec.scala | 6 ++-
.../pekko/stream/scaladsl/RetryFlowSpec.scala | 3 +-
.../pekko/stream/MapAsyncPartitionedSpec.scala | 11 +----
.../main/scala/org/apache/pekko/stream/Shape.scala | 3 +-
.../apache/pekko/stream/SystemMaterializer.scala | 9 ++--
.../scala/org/apache/pekko/stream/impl/FanIn.scala | 3 +-
.../pekko/stream/impl/fusing/FutureFlow.scala | 7 +--
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 12 +----
.../pekko/stream/impl/fusing/SourceSink.scala | 6 +--
.../pekko/stream/impl/io/FileOutputStage.scala | 7 +--
.../pekko/stream/impl/io/InputStreamSource.scala | 7 +--
.../apache/pekko/stream/impl/io/TcpStages.scala | 3 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 3 +-
.../pekko/testkit/CallingThreadDispatcher.scala | 19 ++------
158 files changed, 524 insertions(+), 631 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
