This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch refactor/pekko-style-imports
in repository https://gitbox.apache.org/repos/asf/pekko.git
discard fc019a2a6d refactor: convert org.apache.pekko.X imports to pekko.X
style
add b936e5e1a8 fix: enable strict-unsealed-patmat lint and fix
exhaustiveness warnings (#3330)
add c6454b2d68 Pass input from testQuickUntilPassed to testQuickRecursive
(#3344)
add b3f5bf90cc Check if expected messages are produced (#3351)
add 561ade6484 use lambdas instead of `new Runnable` (#3349)
add 704be7236c fix(stream): notify BroadcastHub consumers on materializer
shutdown (#3346)
add 3b0664a15a refactor: convert org.apache.pekko.X imports to pekko.X
style
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 (fc019a2a6d)
\
N -- N -- N refs/heads/refactor/pekko-style-imports (3b0664a15a)
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:
.../typed/internal/ControlledExecutor.scala | 3 +-
.../actor/testkit/typed/internal/LogbackUtil.scala | 3 +-
.../actor/testkit/typed/javadsl/LogCapturing.scala | 3 +-
.../typed/javadsl/LogCapturingExtension.scala | 3 +-
.../typed/javadsl/TestKitJUnit5Extension.scala | 3 +-
.../javadsl/TestKitJUnitJupiterExtension.scala | 3 +-
.../testkit/typed/scaladsl/LogCapturing.scala | 3 +-
.../testkit/typed/scaladsl/TestAppenderSpec.scala | 3 +-
.../testkit/typed/scaladsl/TestProbeSpec.scala | 3 +-
.../dispatch/ForkJoinPoolVirtualThreadSpec.scala | 37 ++++++++---------
.../org/apache/pekko/PekkoExceptionSpec.scala | 3 +-
.../actor/AbstractActorPreRestartFinalSpec.scala | 3 +-
.../apache/pekko/actor/ReceiveTimeoutSpec.scala | 3 +-
.../scala/org/apache/pekko/actor/TimerSpec.scala | 3 +-
.../pekko/dispatch/ExecutionContextSpec.scala | 37 +++++++----------
.../pekko/pattern/CircuitBreakerMTSpec.scala | 3 +-
.../org/apache/pekko/util/ByteIteratorSpec.scala | 3 +-
.../scala/org/apache/pekko/util/DurationSpec.scala | 3 +-
.../org/apache/pekko/util/ScheduledClockSpec.scala | 3 +-
.../org/apache/pekko/util/TokenBucketSpec.scala | 3 +-
.../other/SerializerOutsidePekkoPackage.scala | 3 +-
.../actor/typed/delivery/TestProducerWithAsk.scala | 2 +-
.../typed/delivery/TestProducerWorkPulling.scala | 2 +-
.../typed/eventstream/EventStreamDocSpec.scala | 3 ++
.../actor/typed/internal/ActorSystemSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/Dispatchers.scala | 3 +-
.../org/apache/pekko/actor/typed/LogOptions.scala | 3 +-
.../pekko/actor/typed/internal/jfr/Events.scala | 3 +-
.../pekko/actor/typed/javadsl/TimerScheduler.scala | 3 +-
.../actor/typed/scaladsl/TimerScheduler.scala | 3 +-
.../org/apache/pekko/util/ByteIterator.scala | 3 +-
.../org/apache/pekko/util/ByteIterator.scala | 3 +-
actor/src/main/scala/org/apache/pekko/Done.scala | 3 +-
.../scala/org/apache/pekko/actor/ActorSystem.scala | 2 +-
.../pekko/actor/LightArrayRevolverScheduler.scala | 4 +-
.../scala/org/apache/pekko/actor/Scheduler.scala | 27 +++++--------
.../dispatch/ForkJoinExecutorConfigurator.scala | 3 +-
.../dispatch/VirtualizedExecutorService.scala | 29 ++++++-------
.../apache/pekko/io/InetAddressDnsProvider.scala | 3 +-
.../org/apache/pekko/io/dns/IdGenerator.scala | 3 +-
.../org/apache/pekko/japi/function/Function.scala | 3 +-
.../org/apache/pekko/pattern/CircuitBreaker.scala | 20 ++++-----
.../scala/org/apache/pekko/routing/Listeners.scala | 3 +-
.../scala/org/apache/pekko/util/ByteString.scala | 3 +-
.../scala/org/apache/pekko/util/Collections.scala | 1 +
.../org/apache/pekko/util/DoubleLinkedList.scala | 3 +-
.../org/apache/pekko/util/FrequencyList.scala | 3 +-
.../org/apache/pekko/util/FrequencySketch.scala | 3 +-
.../org/apache/pekko/util/ImmutableIntMap.scala | 3 +-
.../scala/org/apache/pekko/util/RecencyList.scala | 3 +-
.../main/scala/org/apache/pekko/util/Reflect.scala | 3 +-
.../scala/org/apache/pekko/util/SWARUtil.scala | 3 +-
.../apache/pekko/util/SegmentedRecencyList.scala | 3 +-
.../SerializedSuspendableExecutionContext.scala | 3 +-
.../actor/AffinityPoolIdleCPULevelBenchmark.scala | 3 +-
.../actor/DirectByteBufferPoolBenchmark.scala | 3 +-
.../pekko/actor/ForkJoinActorBenchmark.scala | 3 +-
.../org/apache/pekko/actor/ScheduleBenchmark.scala | 3 +-
.../pekko/actor/StashCreationBenchmark.scala | 3 +-
.../typed/delivery/ReliableDeliveryBenchmark.scala | 8 ++--
.../remote/artery/LiteralEncodingBenchmark.scala | 3 +-
.../remote/compress/HeavyHittersBenchmark.scala | 3 +-
.../pekko/stream/BroadcastHubBenchRunner.scala | 3 +-
.../pekko/stream/BroadcastHubBenchmark.scala | 3 +-
.../stream/GraphStageConstructionBenchmark.scala | 3 +-
.../pekko/stream/StageActorRefBenchmark.scala | 1 +
.../impl/OutputStreamSourceStageBenchmark.scala | 14 +++----
.../pekko/util/ByteString_apply_Benchmark.scala | 3 +-
.../util/ByteString_asInputStream_Benchmark.scala | 3 +-
.../util/ByteString_concat3way_Benchmark.scala | 3 +-
.../util/ByteString_copyToBuffer_Benchmark.scala | 3 +-
.../pekko/util/ByteString_decode_Benchmark.scala | 3 +-
.../util/ByteString_dropRight_Benchmark.scala | 3 +-
.../util/ByteString_dropSliceTake_Benchmark.scala | 3 +-
.../pekko/util/ByteString_drop_Benchmark.scala | 3 +-
.../pekko/util/ByteString_take_Benchmark.scala | 3 +-
.../apache/pekko/util/LruBoundedCacheBench.scala | 3 +-
.../apache/pekko/cluster/metrics/EWMASpec.scala | 3 +-
.../cluster/sharding/typed/internal/Murmur2.scala | 3 +-
.../sharding/typed/ShardedDaemonProcessSpec.scala | 2 +-
.../sharding/typed/ShardingCompileOnlySpec.scala | 2 +-
.../pekko/cluster/sharding/FlightRecording.scala | 3 +-
.../pekko/cluster/sharding/ShardingQueries.scala | 3 +-
.../cluster/sharding/internal/jfr/Events.scala | 3 +-
.../sharding/ShardRegionDataTypesSpec.scala | 2 +
.../sharding/passivation/CompositeSpec.scala | 3 +-
.../passivation/LeastFrequentlyUsedSpec.scala | 3 +-
.../passivation/LeastRecentlyUsedSpec.scala | 3 +-
.../passivation/MostRecentlyUsedSpec.scala | 3 +-
.../passivation/simulator/SimulatorStats.scala | 3 +-
.../pekko/cluster/typed/ActorSystemSpec.scala | 4 +-
.../scala/org/apache/pekko/cluster/Cluster.scala | 4 +-
.../scala/org/apache/pekko/cluster/Gossip.scala | 3 +-
.../org/apache/pekko/cluster/AppVersionSpec.scala | 3 +-
.../apache/pekko/cluster/MultiDcLastNodeSpec.scala | 3 +-
.../pekko/cluster/ClusterDomainEventSpec.scala | 3 +-
.../cluster/JoinConfigCompatCheckerSpec.scala | 3 +-
.../pekko/cluster/ReachabilityPerfSpec.scala | 3 +-
.../org/apache/pekko/cluster/VectorClockSpec.scala | 3 +-
.../cluster/ddata/WildcardSubscribeSpec.scala | 3 +-
.../actor/typed/CoordinatedActorShutdownSpec.scala | 2 +-
.../actor/typed/SharedMutableStateDocSpec.scala | 2 +-
.../test/scala/docs/cluster/FactorialBackend.scala | 3 +-
.../scala/docs/cluster/TransformationBackend.scala | 3 +-
.../docs/cluster/TransformationFrontend.scala | 3 +-
.../scala/docs/coordination/LeaseDocSpec.scala | 3 +-
docs/src/test/scala/docs/ddata/ShoppingCart.scala | 3 +-
.../src/test/scala/docs/io/ScalaUdpMulticast.scala | 3 +-
.../test/scala/docs/io/ScalaUdpMulticastSpec.scala | 3 +-
.../docs/persistence/PersistenceMultiDocSpec.scala | 2 +-
.../PersistenceSchemaEvolutionDocSpec.scala | 3 +-
.../persistence/PersistenceSerializerDocSpec.scala | 3 +-
.../persistence/testkit/PersistenceInitSpec.scala | 3 +-
.../test/scala/docs/stream/FlowErrorDocSpec.scala | 3 +-
.../docs/stream/GraphStageLoggingDocSpec.scala | 3 +-
.../scala/docs/stream/IntegrationDocSpec.scala | 3 +-
.../scala/docs/stream/StreamTestKitDocSpec.scala | 3 +-
.../stream/cookbook/RecipeSourceFromFunction.scala | 3 +-
.../scala/docs/stream/io/StreamFileDocSpec.scala | 3 +-
.../scala/docs/stream/io/StreamTcpDocSpec.scala | 3 +-
.../stream/operators/JavaCollectorDocExample.scala | 3 +-
.../operators/converters/ToFromJavaIOStreams.scala | 3 +-
.../docs/stream/operators/flow/ContraMap.scala | 3 +-
.../scala/docs/stream/operators/flow/Lazy.scala | 3 +-
.../scala/docs/stream/operators/sink/Exists.scala | 3 +-
.../scala/docs/stream/operators/sink/Ignore.scala | 3 +-
.../scala/docs/stream/operators/source/From.scala | 3 +-
.../stream/operators/sourceorflow/Conflate.scala | 3 +-
.../docs/stream/operators/sourceorflow/Split.scala | 3 +-
.../test/scala/docs/testkit/ParentChildSpec.scala | 3 +-
docs/src/test/scala/typed/tutorial_2/IotApp.scala | 3 +-
.../test/scala/typed/tutorial_3/DeviceSpec.scala | 3 +-
.../test/scala/typed/tutorial_4/DeviceGroup.scala | 4 +-
.../scala/typed/tutorial_4/DeviceGroupSpec.scala | 3 +-
.../test/scala/typed/tutorial_5/DeviceGroup.scala | 2 +
.../scala/typed/tutorial_5/DeviceGroupQuery.scala | 2 +
.../typed/tutorial_5/DeviceGroupQuerySpec.scala | 3 +-
.../scala/typed/tutorial_5/DeviceGroupSpec.scala | 3 +-
.../apache/pekko/persistence/query/TestClock.scala | 3 +-
.../query/journal/leveldb/Cleanup.scala | 3 +-
.../persistence/testkit/ProcessingPolicy.scala | 3 +-
.../persistence/testkit/internal/CurrentTime.scala | 3 +-
.../typed/ReplicatedEventPublishingSpec.scala | 2 +-
.../persistence/typed/internal/VersionVector.scala | 3 +-
.../typed/internal/RecoveryPermitterSpec.scala | 2 +-
.../apache/pekko/persistence/JournalProtocol.scala | 3 +-
.../AsyncWriteJournalResponseOrderSpec.scala | 3 +-
.../org/apache/pekko/pki/pem/PEMDecoder.scala | 3 +-
project/Paradox.scala | 2 +-
project/PekkoBuild.scala | 1 +
project/PekkoDisciplinePlugin.scala | 3 +-
project/TestQuickUntilPassed.scala | 12 ++++--
.../remote/artery/BenchmarkFileReporter.scala | 3 +-
.../remote/routing/RemoteRoundRobinSpec.scala | 3 +-
.../remote/routing/RemoteScatterGatherSpec.scala | 3 +-
.../remote/artery/tcp/ssl/SessionVerifier.scala | 3 +-
.../remote/transport/netty/NettySSLSupport.scala | 3 +-
.../apache/pekko/remote/AckedDeliverySpec.scala | 3 +-
.../pekko/remote/artery/ImmutableLongMapSpec.scala | 3 +-
.../artery/RollingEventLogSimulationSpec.scala | 3 +-
.../transport/netty/NettySSLSupportSpec.scala | 3 +-
.../jackson/PekkoSerializationModule.scala | 3 +-
.../jackson/v1withv2/ItemAddedMigration.scala | 3 +-
.../jackson/v2a/CustomerMigration.scala | 3 +-
.../jackson/v2b/ItemAddedMigration.scala | 3 +-
.../jackson/v2c/ItemAddedMigration.scala | 3 +-
.../jackson3/PekkoSerializationModule.scala | 3 +-
.../jackson3/v1withv2/ItemAddedMigration.scala | 3 +-
.../jackson3/v2a/CustomerMigration.scala | 3 +-
.../jackson3/v2b/ItemAddedMigration.scala | 3 +-
.../jackson3/v2c/ItemAddedMigration.scala | 3 +-
.../pekko/stream/testkit/StreamConfiguration.scala | 3 +-
.../stream/tck/CancelledSinkSubscriberTest.scala | 3 +-
.../tck/FlatMapConcatDoubleSubscriberTest.scala | 3 +-
.../tck/PekkoIdentityProcessorVerification.scala | 3 +-
.../stream/tck/PekkoPublisherVerification.scala | 3 +-
.../stream/tck/PekkoSubscriberVerification.scala | 3 +-
.../impl/ResizableMultiReaderRingBufferSpec.scala | 3 +-
.../io/compression/DeflateAutoFlushSpec.scala | 3 +-
.../stream/io/compression/GzipAutoFlushSpec.scala | 3 +-
.../stream/scaladsl/FlowBatchWeightedSpec.scala | 3 +-
.../pekko/stream/scaladsl/FlowConcatSpec.scala | 12 ++----
.../pekko/stream/scaladsl/FlowDropSpec.scala | 3 +-
.../pekko/stream/scaladsl/FlowDropWithinSpec.scala | 3 +-
.../pekko/stream/scaladsl/FlowFromFutureSpec.scala | 3 +-
.../pekko/stream/scaladsl/FlowLimitSpec.scala | 11 ++---
.../apache/pekko/stream/scaladsl/FlowMapSpec.scala | 3 +-
.../pekko/stream/scaladsl/FlowTakeWithinSpec.scala | 3 +-
.../org/apache/pekko/stream/scaladsl/HubSpec.scala | 24 ++++++++++-
.../pekko/stream/scaladsl/LastSinkSpec.scala | 3 +-
.../stream/scaladsl/SubscriberSourceSpec.scala | 3 +-
.../stream/SubscriptionWithCancelException.scala | 3 +-
.../impl/ResizableMultiReaderRingBuffer.scala | 3 +-
.../apache/pekko/stream/impl/SeqActorName.scala | 3 +-
.../stream/impl/UnfoldResourceSourceAsync.scala | 1 +
.../pekko/stream/impl/fusing/DropRepeated.scala | 1 +
.../impl/fusing/GroupedAdjacentByWeighted.scala | 2 +
.../apache/pekko/stream/impl/fusing/Switch.scala | 2 +
.../pekko/stream/impl/io/TlsEngineHelpers.scala | 3 +-
.../org/apache/pekko/stream/scaladsl/Hub.scala | 47 +++++++++++++++-------
.../pekko/stream/scaladsl/StreamConverters.scala | 2 +-
.../org/apache/pekko/testkit/TestBarrier.scala | 3 +-
.../org/apache/pekko/testkit/TestKitUtils.scala | 3 +-
.../scala/org/apache/pekko/testkit/TestLatch.scala | 3 +-
.../scala/org/apache/pekko/testkit/Coroner.scala | 2 +-
.../org/apache/pekko/testkit/TestFSMRefSpec.scala | 3 +-
206 files changed, 347 insertions(+), 490 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
