This is an automated email from the ASF dual-hosted git repository. fanningpj pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pekko.git
commit ac7b5ef066c724f414c9c50fc4ce7da43f37590b Author: He-Pin <[email protected]> AuthorDate: Sun Jan 18 14:19:30 2026 +0800 chore: unfold import selectors in scalafmt --- .scalafmt.conf | 1 + .../main/scala/org/apache/pekko/actor/Stash.scala | 5 ++++- .../org/apache/pekko/dispatch/Mailboxes.scala | 5 ++++- .../apache/pekko/dispatch/ThreadPoolBuilder.scala | 17 +++++++++++++--- .../pekko/pattern/CircuitBreakersRegistry.scala | 7 ++++++- .../scala/org/apache/pekko/pattern/Patterns.scala | 8 ++++++-- .../internal/BackoffOnRestartSupervisor.scala | 8 +++++++- .../pattern/internal/BackoffOnStopSupervisor.scala | 8 +++++++- .../apache/pekko/io/dns/IdGeneratorBanchmark.scala | 11 ++++++++++- .../pekko/cluster/sharding/ShardCoordinator.scala | 4 +++- .../ClusterShardingMessageSerializer.scala | 3 ++- ...eastShardAllocationStrategyRandomizedSpec.scala | 6 +++++- .../pekko/cluster/typed/ClusterSingleton.scala | 3 ++- .../receptionist/ClusterReceptionist.scala | 4 +++- .../test/scala/typed/tutorial_5/DeviceGroup.scala | 6 +++++- .../pekko/remote/testconductor/Conductor.scala | 13 ++++++++++-- .../remote/testconductor/RemoteConnection.scala | 5 ++++- .../javadsl/PersistenceTestKitReadJournal.scala | 6 +++++- .../scaladsl/PersistenceTestKitReadJournal.scala | 5 ++++- .../PersistenceTestKitDurableStateStore.scala | 7 ++++++- .../scaladsl/EventSourcedBehaviorTestKitSpec.scala | 3 ++- .../testkit/scaladsl/ScalaDslUtils.scala | 10 +++++++++- .../pekko/persistence/typed/internal/Running.scala | 16 ++++++++++++--- .../journal/PersistencePluginProxy.scala | 11 +++++++++-- project/PekkoDevelocityPlugin.scala | 5 ++++- .../scala/org/apache/pekko/remote/Endpoint.scala | 5 ++++- .../org/apache/pekko/remote/RemoteDaemon.scala | 13 ++++++++++-- .../transport/ThrottlerTransportAdapter.scala | 6 +++++- .../remote/transport/netty/NettyTransport.scala | 14 +++++++++++-- .../remote/artery/RemoteActorSelectionSpec.scala | 11 ++++++++++- .../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 ++++- .../pekko/stream/io/InputStreamSourceSpec.scala | 6 +++++- .../stream/scaladsl/FlowFlatMapPrefixSpec.scala | 11 +++++++++-- .../pekko/stream/MapAsyncPartitionedSpec.scala | 11 ++++++++++- .../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 ++++++- .../pekko/testkit/CallingThreadDispatcher.scala | 19 +++++++++++++++--- 46 files changed, 312 insertions(+), 62 deletions(-) diff --git a/.scalafmt.conf b/.scalafmt.conf index 78887b58bc..78528b81c3 100644 --- a/.scalafmt.conf +++ b/.scalafmt.conf @@ -24,6 +24,7 @@ binPack.unsafeCallSite = always binPack.unsafeDefnSite = always binPack.indentCallSiteSingleArg = false binPack.indentCallSiteOnce = true +binPack.importSelectors = unfold newlines.avoidForSimpleOverflow = [slc] newlines.source = keep newlines.beforeMultiline = keep diff --git a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala index 5d335d68b4..823253f0ab 100644 --- a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala +++ b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala @@ -20,7 +20,10 @@ import org.apache.pekko import pekko.PekkoException import pekko.annotation.InternalStableApi import pekko.dispatch.{ - DequeBasedMessageQueueSemantics, Envelope, RequiresMessageQueue, UnboundedDequeBasedMessageQueueSemantics + DequeBasedMessageQueueSemantics, + Envelope, + RequiresMessageQueue, + UnboundedDequeBasedMessageQueueSemantics } /** diff --git a/actor/src/main/scala/org/apache/pekko/dispatch/Mailboxes.scala b/actor/src/main/scala/org/apache/pekko/dispatch/Mailboxes.scala index 485c55f808..f3b30140e6 100644 --- a/actor/src/main/scala/org/apache/pekko/dispatch/Mailboxes.scala +++ b/actor/src/main/scala/org/apache/pekko/dispatch/Mailboxes.scala @@ -26,7 +26,10 @@ import pekko.ConfigurationException import pekko.actor.{ Actor, ActorRef, ActorSystem, DeadLetter, Deploy, DynamicAccess, Props } import pekko.annotation.InternalStableApi import pekko.dispatch.sysmsg.{ - EarliestFirstSystemMessageList, LatestFirstSystemMessageList, SystemMessage, SystemMessageList + EarliestFirstSystemMessageList, + LatestFirstSystemMessageList, + SystemMessage, + SystemMessageList } import pekko.event.EventStream import pekko.event.Logging.Warning diff --git a/actor/src/main/scala/org/apache/pekko/dispatch/ThreadPoolBuilder.scala b/actor/src/main/scala/org/apache/pekko/dispatch/ThreadPoolBuilder.scala index af37f95cd4..e1321c7cab 100644 --- a/actor/src/main/scala/org/apache/pekko/dispatch/ThreadPoolBuilder.scala +++ b/actor/src/main/scala/org/apache/pekko/dispatch/ThreadPoolBuilder.scala @@ -15,9 +15,20 @@ package org.apache.pekko.dispatch import java.util.Collection import java.util.concurrent.{ - ArrayBlockingQueue, BlockingQueue, Callable, Executor, ExecutorService, ForkJoinPool, ForkJoinWorkerThread, - LinkedBlockingQueue, RejectedExecutionException, RejectedExecutionHandler, SynchronousQueue, ThreadFactory, - ThreadPoolExecutor, TimeUnit + ArrayBlockingQueue, + BlockingQueue, + Callable, + Executor, + ExecutorService, + ForkJoinPool, + ForkJoinWorkerThread, + LinkedBlockingQueue, + RejectedExecutionException, + RejectedExecutionHandler, + SynchronousQueue, + ThreadFactory, + ThreadPoolExecutor, + TimeUnit } import java.util.concurrent.atomic.{ AtomicLong, AtomicReference } diff --git a/actor/src/main/scala/org/apache/pekko/pattern/CircuitBreakersRegistry.scala b/actor/src/main/scala/org/apache/pekko/pattern/CircuitBreakersRegistry.scala index a2388c5817..c3694e0b0d 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/CircuitBreakersRegistry.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/CircuitBreakersRegistry.scala @@ -20,7 +20,12 @@ import scala.jdk.CollectionConverters._ import org.apache.pekko import pekko.actor.{ - ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension, ExtensionId, ExtensionIdProvider + ActorSystem, + ClassicActorSystemProvider, + ExtendedActorSystem, + Extension, + ExtensionId, + ExtensionIdProvider } import pekko.pattern.internal.CircuitBreakerTelemetryProvider diff --git a/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala b/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala index 9a7d44c161..d39c5862b8 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala @@ -35,8 +35,12 @@ object Patterns { import pekko.actor.ActorRef import pekko.japi import pekko.pattern.{ - after => scalaAfter, ask => scalaAsk, askWithStatus => scalaAskWithStatus, gracefulStop => scalaGracefulStop, - pipe => scalaPipe, retry => scalaRetry + after => scalaAfter, + ask => scalaAsk, + askWithStatus => scalaAskWithStatus, + gracefulStop => scalaGracefulStop, + pipe => scalaPipe, + retry => scalaRetry } import pekko.util.Timeout diff --git a/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnRestartSupervisor.scala b/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnRestartSupervisor.scala index 6140a28796..b9dbefb557 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnRestartSupervisor.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnRestartSupervisor.scala @@ -20,7 +20,13 @@ import pekko.actor.{ OneForOneStrategy, _ } import pekko.actor.SupervisorStrategy._ import pekko.annotation.InternalApi import pekko.pattern.{ - BackoffReset, BackoffSupervisor, ForwardDeathLetters, ForwardTo, HandleBackoff, HandlingWhileStopped, ReplyWith, + BackoffReset, + BackoffSupervisor, + ForwardDeathLetters, + ForwardTo, + HandleBackoff, + HandlingWhileStopped, + ReplyWith, RetrySupport } diff --git a/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnStopSupervisor.scala b/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnStopSupervisor.scala index ae001b0467..20f6ff6585 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnStopSupervisor.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/internal/BackoffOnStopSupervisor.scala @@ -20,7 +20,13 @@ import pekko.actor.{ Actor, ActorLogging, OneForOneStrategy, Props, SupervisorSt import pekko.actor.SupervisorStrategy.{ Directive, Escalate } import pekko.annotation.InternalApi import pekko.pattern.{ - BackoffReset, BackoffSupervisor, ForwardDeathLetters, ForwardTo, HandleBackoff, HandlingWhileStopped, ReplyWith, + BackoffReset, + BackoffSupervisor, + ForwardDeathLetters, + ForwardTo, + HandleBackoff, + HandlingWhileStopped, + ReplyWith, RetrySupport } diff --git a/bench-jmh/src/main/scala/org/apache/pekko/io/dns/IdGeneratorBanchmark.scala b/bench-jmh/src/main/scala/org/apache/pekko/io/dns/IdGeneratorBanchmark.scala index dd4ac13f24..a6fcf21457 100644 --- a/bench-jmh/src/main/scala/org/apache/pekko/io/dns/IdGeneratorBanchmark.scala +++ b/bench-jmh/src/main/scala/org/apache/pekko/io/dns/IdGeneratorBanchmark.scala @@ -21,7 +21,16 @@ import java.security.SecureRandom import java.util.concurrent.{ ThreadLocalRandom, TimeUnit } import org.openjdk.jmh.annotations.{ - Benchmark, BenchmarkMode, Fork, Measurement, Mode, OutputTimeUnit, Scope, State, Threads, Warmup + Benchmark, + BenchmarkMode, + Fork, + Measurement, + Mode, + OutputTimeUnit, + Scope, + State, + Threads, + Warmup } @BenchmarkMode(Array(Mode.Throughput)) diff --git a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala index 357e3bb4ed..c29a8624da 100644 --- a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala +++ b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala @@ -34,7 +34,9 @@ import pekko.cluster.ddata.Replicator._ import pekko.cluster.ddata.SelfUniqueAddress import pekko.cluster.sharding.ShardRegion.ShardId import pekko.cluster.sharding.internal.{ - EventSourcedRememberEntitiesCoordinatorStore, RememberEntitiesCoordinatorStore, RememberEntitiesProvider + EventSourcedRememberEntitiesCoordinatorStore, + RememberEntitiesCoordinatorStore, + RememberEntitiesProvider } import pekko.cluster.sharding.internal.AbstractLeastShardAllocationStrategy import pekko.cluster.sharding.internal.AbstractLeastShardAllocationStrategy.RegionEntry diff --git a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializer.scala b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializer.scala index de9ad97b0a..6951a109a8 100644 --- a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializer.scala +++ b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializer.scala @@ -31,7 +31,8 @@ import pekko.cluster.sharding.Shard import pekko.cluster.sharding.ShardCoordinator import pekko.cluster.sharding.ShardRegion._ import pekko.cluster.sharding.internal.EventSourcedRememberEntitiesCoordinatorStore.{ - MigrationMarker, State => RememberShardsState + MigrationMarker, + State => RememberShardsState } import pekko.cluster.sharding.internal.EventSourcedRememberEntitiesShardStore.{ EntitiesStarted, EntitiesStopped } import pekko.cluster.sharding.internal.EventSourcedRememberEntitiesShardStore.{ State => EntityState } diff --git a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/LeastShardAllocationStrategyRandomizedSpec.scala b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/LeastShardAllocationStrategyRandomizedSpec.scala index d8437d823b..68e398318a 100644 --- a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/LeastShardAllocationStrategyRandomizedSpec.scala +++ b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/LeastShardAllocationStrategyRandomizedSpec.scala @@ -30,7 +30,11 @@ import pekko.testkit.PekkoSpec class LeastShardAllocationStrategyRandomizedSpec extends PekkoSpec("pekko.loglevel = INFO") { import LeastShardAllocationStrategySpec.{ - afterRebalance, countShards, countShardsPerRegion, newFakeRegion, newUpMember + afterRebalance, + countShards, + countShardsPerRegion, + newFakeRegion, + newUpMember } @volatile var clusterMembers: SortedSet[Member] = SortedSet.empty diff --git a/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/ClusterSingleton.scala b/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/ClusterSingleton.scala index f09e5736e2..a4bd03fb27 100644 --- a/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/ClusterSingleton.scala +++ b/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/ClusterSingleton.scala @@ -21,7 +21,8 @@ import pekko.actor.typed._ import pekko.annotation.{ DoNotInherit, InternalApi } import pekko.cluster.ClusterSettings.DataCenter import pekko.cluster.singleton.{ - ClusterSingletonManagerSettings => ClassicClusterSingletonManagerSettings, ClusterSingletonProxySettings + ClusterSingletonManagerSettings => ClassicClusterSingletonManagerSettings, + ClusterSingletonProxySettings } import pekko.cluster.typed.internal.AdaptedClusterSingletonImpl import pekko.coordination.lease.LeaseUsageSettings diff --git a/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionist.scala b/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionist.scala index bf4490bae5..102f3abd00 100644 --- a/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionist.scala +++ b/cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionist.scala @@ -19,7 +19,9 @@ import org.apache.pekko import pekko.actor.Address import pekko.actor.typed.{ ActorRef, Behavior } import pekko.actor.typed.internal.receptionist.{ - AbstractServiceKey, ReceptionistBehaviorProvider, ReceptionistMessages + AbstractServiceKey, + ReceptionistBehaviorProvider, + ReceptionistMessages } import pekko.actor.typed.receptionist.Receptionist.Command import pekko.actor.typed.receptionist.ServiceKey diff --git a/docs/src/test/scala/typed/tutorial_5/DeviceGroup.scala b/docs/src/test/scala/typed/tutorial_5/DeviceGroup.scala index 0b7d8aa230..9e2da39da6 100644 --- a/docs/src/test/scala/typed/tutorial_5/DeviceGroup.scala +++ b/docs/src/test/scala/typed/tutorial_5/DeviceGroup.scala @@ -40,7 +40,11 @@ class DeviceGroup(context: ActorContext[DeviceGroup.Command], groupId: String) extends AbstractBehavior[DeviceGroup.Command](context) { import DeviceGroup._ import DeviceManager.{ - DeviceRegistered, ReplyDeviceList, RequestAllTemperatures, RequestDeviceList, RequestTrackDevice + DeviceRegistered, + ReplyDeviceList, + RequestAllTemperatures, + RequestDeviceList, + RequestTrackDevice } private var deviceIdToActor = Map.empty[String, ActorRef[Device.Command]] diff --git a/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Conductor.scala b/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Conductor.scala index 36e5231bfd..303e09b8c9 100644 --- a/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Conductor.scala +++ b/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Conductor.scala @@ -29,8 +29,17 @@ import org.apache.pekko import pekko.ConfigurationException import pekko.PekkoException import pekko.actor.{ - Actor, ActorRef, Address, DeadLetterSuppression, Deploy, LoggingFSM, NoSerializationVerificationNeeded, - OneForOneStrategy, Props, Status, SupervisorStrategy + Actor, + ActorRef, + Address, + DeadLetterSuppression, + Deploy, + LoggingFSM, + NoSerializationVerificationNeeded, + OneForOneStrategy, + Props, + Status, + SupervisorStrategy } import pekko.event.{ Logging, LoggingAdapter } import pekko.event.LoggingReceive diff --git a/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/RemoteConnection.scala b/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/RemoteConnection.scala index 026d0dfe01..ae9504934b 100644 --- a/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/RemoteConnection.scala +++ b/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/RemoteConnection.scala @@ -30,7 +30,10 @@ import io.netty.channel.nio.NioIoHandler import io.netty.channel.socket.SocketChannel import io.netty.channel.socket.nio.{ NioServerSocketChannel, NioSocketChannel } import io.netty.handler.codec.{ - LengthFieldBasedFrameDecoder, LengthFieldPrepender, MessageToMessageDecoder, MessageToMessageEncoder + LengthFieldBasedFrameDecoder, + LengthFieldPrepender, + MessageToMessageDecoder, + MessageToMessageEncoder } /** diff --git a/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/javadsl/PersistenceTestKitReadJournal.scala b/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/javadsl/PersistenceTestKitReadJournal.scala index af738f8e0f..49f63684bb 100644 --- a/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/javadsl/PersistenceTestKitReadJournal.scala +++ b/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/javadsl/PersistenceTestKitReadJournal.scala @@ -19,7 +19,11 @@ import pekko.japi.Pair import pekko.persistence.query.EventEnvelope import pekko.persistence.query.Offset import pekko.persistence.query.javadsl.{ - CurrentEventsByPersistenceIdQuery, CurrentEventsByTagQuery, EventsByPersistenceIdQuery, EventsByTagQuery, ReadJournal + CurrentEventsByPersistenceIdQuery, + CurrentEventsByTagQuery, + EventsByPersistenceIdQuery, + EventsByTagQuery, + ReadJournal } import pekko.persistence.query.typed import pekko.persistence.query.typed.javadsl.{ CurrentEventsBySliceQuery, EventsBySliceQuery } diff --git a/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/scaladsl/PersistenceTestKitReadJournal.scala b/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/scaladsl/PersistenceTestKitReadJournal.scala index 510cb2cb97..73c7945160 100644 --- a/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/scaladsl/PersistenceTestKitReadJournal.scala +++ b/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/scaladsl/PersistenceTestKitReadJournal.scala @@ -24,7 +24,10 @@ import pekko.persistence.query.{ EventEnvelope, Sequence } import pekko.persistence.query.NoOffset import pekko.persistence.query.Offset import pekko.persistence.query.scaladsl.{ - CurrentEventsByPersistenceIdQuery, CurrentEventsByTagQuery, EventsByPersistenceIdQuery, PagedPersistenceIdsQuery, + CurrentEventsByPersistenceIdQuery, + CurrentEventsByTagQuery, + EventsByPersistenceIdQuery, + PagedPersistenceIdsQuery, ReadJournal } import pekko.persistence.query.scaladsl.EventsByTagQuery diff --git a/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/state/scaladsl/PersistenceTestKitDurableStateStore.scala b/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/state/scaladsl/PersistenceTestKitDurableStateStore.scala index fb31657241..414a9f1962 100644 --- a/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/state/scaladsl/PersistenceTestKitDurableStateStore.scala +++ b/persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/state/scaladsl/PersistenceTestKitDurableStateStore.scala @@ -23,7 +23,12 @@ import pekko.{ Done, NotUsed } import pekko.actor.ExtendedActorSystem import pekko.persistence.Persistence import pekko.persistence.query.{ - DeletedDurableState, DurableStateChange, NoOffset, Offset, Sequence, UpdatedDurableState + DeletedDurableState, + DurableStateChange, + NoOffset, + Offset, + Sequence, + UpdatedDurableState } import pekko.persistence.query.scaladsl.{ DurableStateStorePagedPersistenceIdsQuery, DurableStateStoreQuery } import pekko.persistence.query.typed.scaladsl.DurableStateStoreBySliceQuery diff --git a/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/EventSourcedBehaviorTestKitSpec.scala b/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/EventSourcedBehaviorTestKitSpec.scala index dd75fbbb2d..5c8c4781bf 100644 --- a/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/EventSourcedBehaviorTestKitSpec.scala +++ b/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/EventSourcedBehaviorTestKitSpec.scala @@ -26,7 +26,8 @@ import pekko.actor.typed.Behavior import pekko.actor.typed.scaladsl.ActorContext import pekko.actor.typed.scaladsl.Behaviors import pekko.persistence.testkit.scaladsl.EventSourcedBehaviorTestKitSpec.TestCounter.{ - NotSerializableState, NullState + NotSerializableState, + NullState } import pekko.persistence.typed.PersistenceId import pekko.persistence.typed.internal.JournalFailureException diff --git a/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/ScalaDslUtils.scala b/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/ScalaDslUtils.scala index c67f560039..54e44371c6 100644 --- a/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/ScalaDslUtils.scala +++ b/persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/ScalaDslUtils.scala @@ -16,7 +16,15 @@ package org.apache.pekko.persistence.testkit.scaladsl import org.apache.pekko import pekko.actor.typed.ActorRef import pekko.persistence.testkit.{ - Cmd, CommonUtils, EmptyState, Evt, NonEmptyState, Passivate, Recovered, Stopped, TestCommand + Cmd, + CommonUtils, + EmptyState, + Evt, + NonEmptyState, + Passivate, + Recovered, + Stopped, + TestCommand } import pekko.persistence.typed.PersistenceId import pekko.persistence.typed.RecoveryCompleted diff --git a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/Running.scala b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/Running.scala index 35068f4fbd..e5f38625e7 100644 --- a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/Running.scala +++ b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/Running.scala @@ -47,9 +47,19 @@ import pekko.persistence.journal.Tagged import pekko.persistence.query.{ EventEnvelope, PersistenceQuery } import pekko.persistence.query.scaladsl.EventsByPersistenceIdQuery import pekko.persistence.typed.{ - DeleteEventsCompleted, DeleteEventsFailed, DeleteSnapshotsCompleted, DeleteSnapshotsFailed, DeletionTarget, - EventRejectedException, JournalPersistFailed, JournalPersistRejected, PersistenceId, SnapshotCompleted, - SnapshotFailed, SnapshotMetadata, SnapshotSelectionCriteria + DeleteEventsCompleted, + DeleteEventsFailed, + DeleteSnapshotsCompleted, + DeleteSnapshotsFailed, + DeletionTarget, + EventRejectedException, + JournalPersistFailed, + JournalPersistRejected, + PersistenceId, + SnapshotCompleted, + SnapshotFailed, + SnapshotMetadata, + SnapshotSelectionCriteria } import pekko.persistence.typed.ReplicaId import pekko.persistence.typed.ReplicationId diff --git a/persistence/src/main/scala/org/apache/pekko/persistence/journal/PersistencePluginProxy.scala b/persistence/src/main/scala/org/apache/pekko/persistence/journal/PersistencePluginProxy.scala index a947e851fa..01b2fe8b90 100644 --- a/persistence/src/main/scala/org/apache/pekko/persistence/journal/PersistencePluginProxy.scala +++ b/persistence/src/main/scala/org/apache/pekko/persistence/journal/PersistencePluginProxy.scala @@ -21,8 +21,15 @@ import scala.concurrent.duration._ import org.apache.pekko import pekko.actor._ import pekko.persistence.{ - AtomicWrite, DeleteMessagesFailure, DeleteSnapshotFailure, DeleteSnapshotsFailure, JournalProtocol, NonPersistentRepr, - Persistence, SaveSnapshotFailure, SnapshotProtocol + AtomicWrite, + DeleteMessagesFailure, + DeleteSnapshotFailure, + DeleteSnapshotsFailure, + JournalProtocol, + NonPersistentRepr, + Persistence, + SaveSnapshotFailure, + SnapshotProtocol } import pekko.util.Helpers.Requiring diff --git a/project/PekkoDevelocityPlugin.scala b/project/PekkoDevelocityPlugin.scala index 0092a15d65..01a0602847 100644 --- a/project/PekkoDevelocityPlugin.scala +++ b/project/PekkoDevelocityPlugin.scala @@ -17,7 +17,10 @@ import com.gradle.develocity.agent.sbt.DevelocityPlugin import com.gradle.develocity.agent.sbt.DevelocityPlugin.autoImport.{ - develocityConfiguration, FlakyTestPolicy, ProjectId, Publishing + develocityConfiguration, + FlakyTestPolicy, + ProjectId, + Publishing } import sbt.{ inConfig, url, AutoPlugin, Def, PluginTrigger, Plugins, Setting } import sbt.Keys.insideCI diff --git a/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala b/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala index be63b5c6dd..c6b379685d 100644 --- a/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala +++ b/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala @@ -38,7 +38,10 @@ import pekko.remote.EndpointWriter.{ FlushAndStop, StoppedReading } import pekko.remote.WireFormats.SerializedMessage import pekko.remote.transport._ import pekko.remote.transport.AssociationHandle.{ - ActorHandleEventListener, DisassociateInfo, Disassociated, InboundPayload + ActorHandleEventListener, + DisassociateInfo, + Disassociated, + InboundPayload } import pekko.remote.transport.PekkoPduCodec.Message import pekko.remote.transport.Transport.InvalidAssociationException diff --git a/remote/src/main/scala/org/apache/pekko/remote/RemoteDaemon.scala b/remote/src/main/scala/org/apache/pekko/remote/RemoteDaemon.scala index e7c195669c..01509ec4b3 100644 --- a/remote/src/main/scala/org/apache/pekko/remote/RemoteDaemon.scala +++ b/remote/src/main/scala/org/apache/pekko/remote/RemoteDaemon.scala @@ -21,8 +21,17 @@ import scala.util.control.NonFatal import org.apache.pekko import pekko.actor.{ - Actor, ActorPath, ActorPathExtractor, ActorRef, ActorSystemImpl, AddressTerminated, Deploy, InternalActorRef, Nobody, - Props, VirtualPathContainer + Actor, + ActorPath, + ActorPathExtractor, + ActorRef, + ActorSystemImpl, + AddressTerminated, + Deploy, + InternalActorRef, + Nobody, + Props, + VirtualPathContainer } import pekko.actor.ActorIdentity import pekko.actor.ActorRefScope diff --git a/remote/src/main/scala/org/apache/pekko/remote/transport/ThrottlerTransportAdapter.scala b/remote/src/main/scala/org/apache/pekko/remote/transport/ThrottlerTransportAdapter.scala index daec54343d..2660b21b19 100644 --- a/remote/src/main/scala/org/apache/pekko/remote/transport/ThrottlerTransportAdapter.scala +++ b/remote/src/main/scala/org/apache/pekko/remote/transport/ThrottlerTransportAdapter.scala @@ -35,7 +35,11 @@ import pekko.pattern.{ ask, pipe, PromiseActorRef } import pekko.remote.RARP import pekko.remote.transport.ActorTransportAdapter.AssociateUnderlying import pekko.remote.transport.AssociationHandle.{ - ActorHandleEventListener, DisassociateInfo, Disassociated, HandleEventListener, InboundPayload + ActorHandleEventListener, + DisassociateInfo, + Disassociated, + HandleEventListener, + InboundPayload } import pekko.remote.transport.PekkoPduCodec.Associate import pekko.remote.transport.ThrottlerManager.{ Checkin, Handle, Listener, ListenerAndMode } diff --git a/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala b/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala index 56ab768c3d..6cad95e682 100644 --- a/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala +++ b/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala @@ -38,10 +38,20 @@ import pekko.util.Helpers.Requiring import io.netty.bootstrap.{ Bootstrap => ClientBootstrap, ServerBootstrap } import io.netty.buffer.{ - AdaptiveByteBufAllocator, ByteBufAllocator, PooledByteBufAllocator, Unpooled, UnpooledByteBufAllocator + AdaptiveByteBufAllocator, + ByteBufAllocator, + PooledByteBufAllocator, + Unpooled, + UnpooledByteBufAllocator } import io.netty.channel.{ - Channel, ChannelFuture, ChannelHandlerContext, ChannelInitializer, ChannelOption, ChannelPipeline, EventLoopGroup, + Channel, + ChannelFuture, + ChannelHandlerContext, + ChannelInitializer, + ChannelOption, + ChannelPipeline, + EventLoopGroup, MultiThreadIoEventLoopGroup } import io.netty.channel.group.{ ChannelGroup, ChannelGroupFuture, ChannelMatchers, DefaultChannelGroup } diff --git a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteActorSelectionSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteActorSelectionSpec.scala index 96d83b4542..30461e2bd8 100644 --- a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteActorSelectionSpec.scala +++ b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteActorSelectionSpec.scala @@ -17,7 +17,16 @@ import scala.concurrent.duration._ import org.apache.pekko import pekko.actor.{ - Actor, ActorIdentity, ActorLogging, ActorRef, ActorRefScope, ActorSelection, Identify, PoisonPill, Props, Terminated + Actor, + ActorIdentity, + ActorLogging, + ActorRef, + ActorRefScope, + ActorSelection, + Identify, + PoisonPill, + Props, + Terminated } import pekko.testkit.{ ImplicitSender, TestActors } import pekko.testkit.JavaSerializable diff --git a/remote/src/test/scala/org/apache/pekko/remote/classic/transport/PekkoProtocolSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/classic/transport/PekkoProtocolSpec.scala index c591400f74..f869337eed 100644 --- a/remote/src/test/scala/org/apache/pekko/remote/classic/transport/PekkoProtocolSpec.scala +++ b/remote/src/test/scala/org/apache/pekko/remote/classic/transport/PekkoProtocolSpec.scala @@ -26,7 +26,10 @@ import pekko.remote.{ FailureDetector, WireFormats } import pekko.remote.classic.transport.PekkoProtocolSpec.TestFailureDetector import pekko.remote.transport.{ AssociationRegistry => _, _ } import pekko.remote.transport.AssociationHandle.{ - ActorHandleEventListener, DisassociateInfo, Disassociated, InboundPayload + ActorHandleEventListener, + DisassociateInfo, + Disassociated, + InboundPayload } import pekko.remote.transport.PekkoPduCodec.{ Associate, Disassociate, Heartbeat } import pekko.remote.transport.ProtocolStateActor diff --git a/remote/src/test/scala/org/apache/pekko/remote/serialization/ArteryMessageSerializerSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/serialization/ArteryMessageSerializerSpec.scala index e42b45d050..7810e6acc9 100644 --- a/remote/src/test/scala/org/apache/pekko/remote/serialization/ArteryMessageSerializerSpec.scala +++ b/remote/src/test/scala/org/apache/pekko/remote/serialization/ArteryMessageSerializerSpec.scala @@ -23,7 +23,9 @@ import pekko.remote.artery.Flush import pekko.remote.artery.FlushAck import pekko.remote.artery.OutboundHandshake.{ HandshakeReq, HandshakeRsp } import pekko.remote.artery.compress.CompressionProtocol.{ - ActorRefCompressionAdvertisement, ActorRefCompressionAdvertisementAck, ClassManifestCompressionAdvertisement, + ActorRefCompressionAdvertisement, + ActorRefCompressionAdvertisementAck, + ClassManifestCompressionAdvertisement, ClassManifestCompressionAdvertisementAck } import pekko.remote.artery.compress.CompressionTable diff --git a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonObjectMapperProvider.scala b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonObjectMapperProvider.scala index 860eaffa63..567307f7fc 100644 --- a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonObjectMapperProvider.scala +++ b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonObjectMapperProvider.scala @@ -23,13 +23,23 @@ import scala.util.{ Failure, Success } import com.fasterxml.jackson.annotation.{ JsonAutoDetect, JsonCreator, PropertyAccessor } import com.fasterxml.jackson.core.{ - JsonFactory, JsonFactoryBuilder, JsonGenerator, JsonParser, StreamReadConstraints, StreamReadFeature, - StreamWriteConstraints, StreamWriteFeature + JsonFactory, + JsonFactoryBuilder, + JsonGenerator, + JsonParser, + StreamReadConstraints, + StreamReadFeature, + StreamWriteConstraints, + StreamWriteFeature } import com.fasterxml.jackson.core.json.{ JsonReadFeature, JsonWriteFeature } import com.fasterxml.jackson.core.util.{ BufferRecycler, JsonRecyclerPools, RecyclerPool } import com.fasterxml.jackson.databind.{ - DeserializationFeature, MapperFeature, Module, ObjectMapper, SerializationFeature + DeserializationFeature, + MapperFeature, + Module, + ObjectMapper, + SerializationFeature } import com.fasterxml.jackson.databind.cfg.EnumFeature import com.fasterxml.jackson.databind.json.JsonMapper @@ -37,7 +47,12 @@ import com.fasterxml.jackson.module.paramnames.ParameterNamesModule import org.apache.pekko import pekko.actor.{ - ActorSystem, ClassicActorSystemProvider, DynamicAccess, ExtendedActorSystem, Extension, ExtensionId, + ActorSystem, + ClassicActorSystemProvider, + DynamicAccess, + ExtendedActorSystem, + Extension, + ExtensionId, ExtensionIdProvider } import pekko.actor.setup.Setup diff --git a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonObjectMapperProvider.scala b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonObjectMapperProvider.scala index 2897048b05..ae83185ba2 100644 --- a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonObjectMapperProvider.scala +++ b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonObjectMapperProvider.scala @@ -27,7 +27,11 @@ import tools.jackson.core.{ StreamReadConstraints, StreamReadFeature, StreamWrit import tools.jackson.core.json.{ JsonFactory, JsonReadFeature, JsonWriteFeature } import tools.jackson.core.util.{ BufferRecycler, JsonRecyclerPools, RecyclerPool } import tools.jackson.databind.{ - DeserializationFeature, JacksonModule, MapperFeature, ObjectMapper, SerializationFeature + DeserializationFeature, + JacksonModule, + MapperFeature, + ObjectMapper, + SerializationFeature } import tools.jackson.databind.cfg.{ DateTimeFeature, EnumFeature, MapperBuilder } import tools.jackson.databind.introspect.VisibilityChecker @@ -36,7 +40,12 @@ import tools.jackson.dataformat.cbor.{ CBORFactory, CBORMapper } import org.apache.pekko import pekko.actor.{ - ActorSystem, ClassicActorSystemProvider, DynamicAccess, ExtendedActorSystem, Extension, ExtensionId, + ActorSystem, + ClassicActorSystemProvider, + DynamicAccess, + ExtendedActorSystem, + Extension, + ExtensionId, ExtensionIdProvider } import pekko.actor.setup.Setup diff --git a/serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/JacksonSerializerSpec.scala b/serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/JacksonSerializerSpec.scala index b1e1128c36..d0a8084d9c 100644 --- a/serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/JacksonSerializerSpec.scala +++ b/serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/JacksonSerializerSpec.scala @@ -29,7 +29,11 @@ import com.fasterxml.jackson.annotation.{ JsonIgnore, JsonSubTypes, JsonTypeInfo import tools.jackson.core.{ JsonGenerator, StreamReadFeature, StreamWriteFeature } import tools.jackson.core.`type`.TypeReference import tools.jackson.databind.{ - DeserializationFeature, JacksonModule, MapperFeature, SerializationContext, SerializationFeature + DeserializationFeature, + JacksonModule, + MapperFeature, + SerializationContext, + SerializationFeature } import tools.jackson.databind.annotation.{ JsonDeserialize, JsonSerialize } import tools.jackson.databind.cfg.DateTimeFeature diff --git a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/StreamTestKit.scala b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/StreamTestKit.scala index 361dc9cd0d..36abb43fc8 100644 --- a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/StreamTestKit.scala +++ b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/StreamTestKit.scala @@ -25,7 +25,11 @@ import scala.reflect.ClassTag import org.apache.pekko import pekko.actor.{ - ActorRef, ActorSystem, ClassicActorSystemProvider, DeadLetterSuppression, NoSerializationVerificationNeeded + ActorRef, + ActorSystem, + ClassicActorSystemProvider, + DeadLetterSuppression, + NoSerializationVerificationNeeded } import pekko.japi._ import pekko.stream._ diff --git a/stream-testkit/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterSpecKit.scala b/stream-testkit/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterSpecKit.scala index 02a419d106..46bf05c5ac 100644 --- a/stream-testkit/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterSpecKit.scala +++ b/stream-testkit/src/test/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreterSpecKit.scala @@ -27,7 +27,10 @@ import pekko.event.Logging import pekko.stream._ import pekko.stream.Supervision.Decider import pekko.stream.impl.fusing.GraphInterpreter.{ - Connection, DownstreamBoundaryStageLogic, Failed, UpstreamBoundaryStageLogic + Connection, + DownstreamBoundaryStageLogic, + Failed, + UpstreamBoundaryStageLogic } import pekko.stream.stage.{ GraphStage, GraphStageLogic, InHandler, OutHandler, _ } import pekko.stream.testkit.StreamSpec diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/io/InputStreamSourceSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/io/InputStreamSourceSpec.scala index 67622ebdfd..fa6de2b7ed 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/io/InputStreamSourceSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/io/InputStreamSourceSpec.scala @@ -22,7 +22,11 @@ import scala.util.Success import org.apache.pekko import pekko.Done import pekko.stream.{ - AbruptStageTerminationException, ActorMaterializer, ActorMaterializerSettings, IOResult, Materializer + AbruptStageTerminationException, + ActorMaterializer, + ActorMaterializerSettings, + IOResult, + Materializer } import pekko.stream.scaladsl.{ Keep, Sink, StreamConverters } import pekko.stream.testkit._ diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapPrefixSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapPrefixSpec.scala index ecf3818846..6f6f25742e 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapPrefixSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapPrefixSpec.scala @@ -16,8 +16,15 @@ package org.apache.pekko.stream.scaladsl import org.apache.pekko import pekko.{ Done, NotUsed } import pekko.stream.{ - AbruptStageTerminationException, AbruptTerminationException, Attributes, FlowShape, Inlet, Materializer, - NeverMaterializedException, Outlet, SubscriptionWithCancelException + AbruptStageTerminationException, + AbruptTerminationException, + Attributes, + FlowShape, + Inlet, + Materializer, + NeverMaterializedException, + Outlet, + SubscriptionWithCancelException } import pekko.stream.Attributes.Attribute import pekko.stream.stage.{ GraphStage, GraphStageLogic, InHandler, OutHandler } diff --git a/stream-typed-tests/src/test/scala/org/apache/pekko/stream/MapAsyncPartitionedSpec.scala b/stream-typed-tests/src/test/scala/org/apache/pekko/stream/MapAsyncPartitionedSpec.scala index 05ef299b5a..765b335a78 100644 --- a/stream-typed-tests/src/test/scala/org/apache/pekko/stream/MapAsyncPartitionedSpec.scala +++ b/stream-typed-tests/src/test/scala/org/apache/pekko/stream/MapAsyncPartitionedSpec.scala @@ -32,7 +32,16 @@ import org.apache.pekko import pekko.actor.typed.ActorSystem import pekko.actor.typed.scaladsl.Behaviors import pekko.stream.scaladsl.{ - Flow, FlowWithContext, GraphDSL, Keep, RunnableGraph, Sink, Source, SourceWithContext, Unzip, Zip + Flow, + FlowWithContext, + GraphDSL, + Keep, + RunnableGraph, + Sink, + Source, + SourceWithContext, + Unzip, + Zip } import pekko.stream.testkit.scaladsl.TestSink diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FutureFlow.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FutureFlow.scala index 914e05d13c..0deea88007 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FutureFlow.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FutureFlow.scala @@ -21,7 +21,12 @@ import scala.util.control.NonFatal import org.apache.pekko import pekko.annotation.InternalApi import pekko.stream.{ - AbruptStageTerminationException, Attributes, FlowShape, Inlet, NeverMaterializedException, Outlet + AbruptStageTerminationException, + Attributes, + FlowShape, + Inlet, + NeverMaterializedException, + Outlet } import pekko.stream.Attributes.SourceLocation import pekko.stream.impl.Stages.DefaultAttributes diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala index 6bcbb63dea..352bd64fa7 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala @@ -37,12 +37,20 @@ import pekko.stream.Attributes.SourceLocation import pekko.stream.OverflowStrategies._ import pekko.stream.Supervision.Decider import pekko.stream.impl.{ - Buffer => BufferImpl, ContextPropagation, FailedSource, JavaStreamSource, ReactiveStreamsCompliance, TraversalBuilder + Buffer => BufferImpl, + ContextPropagation, + FailedSource, + JavaStreamSource, + ReactiveStreamsCompliance, + TraversalBuilder } import pekko.stream.impl.Stages.DefaultAttributes import pekko.stream.impl.fusing.GraphStages.{ FutureSource, SimpleLinearGraphStage, SingleSource } import pekko.stream.scaladsl.{ - DelayStrategy, Source, StatefulMapConcatAccumulator, StatefulMapConcatAccumulatorFactory + DelayStrategy, + Source, + StatefulMapConcatAccumulator, + StatefulMapConcatAccumulatorFactory } import pekko.stream.stage._ import pekko.util.{ ConstantFun, OptionVal } diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala index 3dbdd058f0..2a447293fa 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala @@ -25,7 +25,11 @@ import pekko.stream.{ ActorAttributes, Attributes, Inlet, SinkShape, StreamSubsc import pekko.stream.ActorAttributes.StreamSubscriptionTimeout import pekko.stream.scaladsl.Source import pekko.stream.stage.{ - GraphStageLogic, GraphStageWithMaterializedValue, InHandler, OutHandler, TimerGraphStageLogic + GraphStageLogic, + GraphStageWithMaterializedValue, + InHandler, + OutHandler, + TimerGraphStageLogic } /** diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/io/FileOutputStage.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/io/FileOutputStage.scala index eebcb01def..fd665b51a6 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/io/FileOutputStage.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/io/FileOutputStage.scala @@ -25,7 +25,12 @@ import scala.util.control.NonFatal import org.apache.pekko import pekko.annotation.InternalApi import pekko.stream.{ - AbruptStageTerminationException, Attributes, IOOperationIncompleteException, IOResult, Inlet, SinkShape + AbruptStageTerminationException, + Attributes, + IOOperationIncompleteException, + IOResult, + Inlet, + SinkShape } import pekko.stream.impl.Stages.DefaultAttributes import pekko.stream.stage.{ GraphStageLogic, GraphStageWithMaterializedValue, InHandler } diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/io/InputStreamSource.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/io/InputStreamSource.scala index 5fe0631ba0..fd7c51c8aa 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/io/InputStreamSource.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/io/InputStreamSource.scala @@ -21,7 +21,12 @@ import scala.util.control.NonFatal import org.apache.pekko import pekko.annotation.InternalApi import pekko.stream.{ - AbruptStageTerminationException, Attributes, IOOperationIncompleteException, IOResult, Outlet, SourceShape, + AbruptStageTerminationException, + Attributes, + IOOperationIncompleteException, + IOResult, + Outlet, + SourceShape, SubscriptionWithCancelException } import pekko.stream.impl.Stages.DefaultAttributes diff --git a/testkit/src/main/scala/org/apache/pekko/testkit/CallingThreadDispatcher.scala b/testkit/src/main/scala/org/apache/pekko/testkit/CallingThreadDispatcher.scala index e43abc9370..8a34ecb0d4 100644 --- a/testkit/src/main/scala/org/apache/pekko/testkit/CallingThreadDispatcher.scala +++ b/testkit/src/main/scala/org/apache/pekko/testkit/CallingThreadDispatcher.scala @@ -24,11 +24,24 @@ import scala.util.control.NonFatal import org.apache.pekko import pekko.actor.{ - ActorCell, ActorInitializationException, ActorRef, ExtendedActorSystem, Extension, ExtensionId, ExtensionIdProvider + ActorCell, + ActorInitializationException, + ActorRef, + ExtendedActorSystem, + Extension, + ExtensionId, + ExtensionIdProvider } import pekko.dispatch.{ - DefaultSystemMessageQueue, DispatcherPrerequisites, Envelope, Mailbox, MailboxType, MessageDispatcher, - MessageDispatcherConfigurator, MessageQueue, TaskInvocation + DefaultSystemMessageQueue, + DispatcherPrerequisites, + Envelope, + Mailbox, + MailboxType, + MessageDispatcher, + MessageDispatcherConfigurator, + MessageQueue, + TaskInvocation } import pekko.dispatch.sysmsg.{ Resume, Suspend, SystemMessage } import pekko.util.Switch --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
