Reformat

Author: PawelLipski

examples/akka-cluster-app/src/main/scala/org/virtuslab/example/ExampleSerializer.scala

@@ -8,7 +8,8 @@ import org.virtuslab.ash.circe.Register
 import org.virtuslab.ash.circe.Registration
 
 @Serializer(classOf[CirceAkkaSerializable], Register.REGISTRATION_REGEX)
-class ExampleSerializer(actorSystem: ExtendedActorSystem) extends CirceAkkaSerializer[CirceAkkaSerializable](actorSystem) {
+class ExampleSerializer(actorSystem: ExtendedActorSystem)
+    extends CirceAkkaSerializer[CirceAkkaSerializable](actorSystem) {
   override def identifier: Int = 2137
 
   override lazy val codecs: Seq[Registration[_ <: CirceAkkaSerializable]] = Seq(

examples/akka-cluster-app/src/main/scala/org/virtuslab/example/StatsService.scala

@@ -68,7 +68,10 @@ object StatsAggregator {
       waiting(replyTo, words.size, Nil)
     }
 
-  private def waiting(replyTo: ActorRef[StatsService.Response], expectedResponses: Int, results: List[Int]): Behavior[Event] =
+  private def waiting(
+      replyTo: ActorRef[StatsService.Response],
+      expectedResponses: Int,
+      results: List[Int]): Behavior[Event] =
     Behaviors.receiveMessage {
       case CalculationComplete(length) =>
         val newResults = results :+ length

examples/akka-persistence-app/src/main/scala/org/virtuslab/example/ExampleSerializer.scala

@@ -8,7 +8,8 @@ import org.virtuslab.ash.circe.Register
 import org.virtuslab.ash.circe.Registration
 
 @Serializer(classOf[CirceAkkaSerializable], Register.REGISTRATION_REGEX)
-class ExampleSerializer(actorSystem: ExtendedActorSystem) extends CirceAkkaSerializer[CirceAkkaSerializable](actorSystem) {
+class ExampleSerializer(actorSystem: ExtendedActorSystem)
+    extends CirceAkkaSerializer[CirceAkkaSerializable](actorSystem) {
   override def identifier: Int = 7312
 
   override lazy val codecs: Seq[Registration[_ <: CirceAkkaSerializable]] = Seq(

examples/akka-persistence-app/src/main/scala/org/virtuslab/example/ShoppingCart.scala

@@ -51,8 +51,8 @@ object ShoppingCart {
   /**
    * A command to add an item to the cart.
    *
-   * It replies with `StatusReply[Summary]`, which is sent back to the caller when all the events emitted by this command are
-   * successfully persisted.
+   * It replies with `StatusReply[Summary]`, which is sent back to the caller when all the events emitted by this
+   * command are successfully persisted.
    */
   final case class AddItem(itemId: String, quantity: Int, replyTo: ActorRef[StatusReply[Summary]]) extends Command
 

examples/akka-persistence-app/src/main/scala/org/virtuslab/example/repository/ScalikeJdbcSetup.scala

@@ -15,7 +15,8 @@ import scalikejdbc.config.TypesafeConfigReader
 object ScalikeJdbcSetup {
 
   /**
-   * Initiate the ScalikeJDBC connection pool configuration and shutdown. The DataSource is setup with ActorSystem's config.
+   * Initiate the ScalikeJDBC connection pool configuration and shutdown. The DataSource is setup with ActorSystem's
+   * config.
    *
    * The connection pool will be closed when the actor system terminates.
    */
@@ -28,8 +29,8 @@ object ScalikeJdbcSetup {
   }
 
   /**
-   * Builds a Hikari DataSource with values from jdbc-connection-settings. The DataSource is then configured as the 'default'
-   * connection pool for ScalikeJDBC.
+   * Builds a Hikari DataSource with values from jdbc-connection-settings. The DataSource is then configured as the
+   * 'default' connection pool for ScalikeJDBC.
    */
   private def initFromConfig(config: Config): Unit = {
 
@@ -61,7 +62,11 @@ object ScalikeJdbcSetup {
   /**
    * This is only needed to allow ScalikeJdbc to load its logging configurations from the passed Config
    */
-  private class DBsFromConfig(val config: Config) extends DBs with TypesafeConfigReader with TypesafeConfig with NoEnvPrefix
+  private class DBsFromConfig(val config: Config)
+      extends DBs
+      with TypesafeConfigReader
+      with TypesafeConfig
+      with NoEnvPrefix
 
   /**
    * ScalikeJdbc needs a closer for the DataSource to delegate the closing call.

examples/akka-persistence-app/src/test/scala/org.virtuslab/example/ShoppingCartSpec.scala

@@ -23,11 +23,16 @@ object ShoppingCartSpec {
     .withFallback(EventSourcedBehaviorTestKit.config)
 }
 
-class ShoppingCartSpec extends ScalaTestWithActorTestKit(ShoppingCartSpec.config) with AnyWordSpecLike with BeforeAndAfterEach {
+class ShoppingCartSpec
+    extends ScalaTestWithActorTestKit(ShoppingCartSpec.config)
+    with AnyWordSpecLike
+    with BeforeAndAfterEach {
 
   private val cartId = "testCart"
   private val eventSourcedTestKit =
-    EventSourcedBehaviorTestKit[ShoppingCart.Command, ShoppingCart.Event, ShoppingCart.State](system, ShoppingCart(cartId))
+    EventSourcedBehaviorTestKit[ShoppingCart.Command, ShoppingCart.Event, ShoppingCart.State](
+      system,
+      ShoppingCart(cartId))
 
   override protected def beforeEach(): Unit = {
     super.beforeEach()
@@ -38,7 +43,8 @@ class ShoppingCartSpec extends ScalaTestWithActorTestKit(ShoppingCartSpec.config
 
     "add item" in {
       val result1 =
-        eventSourcedTestKit.runCommand[StatusReply[ShoppingCart.Summary]](replyTo => ShoppingCart.AddItem("foo", 42, replyTo))
+        eventSourcedTestKit.runCommand[StatusReply[ShoppingCart.Summary]](replyTo =>
+          ShoppingCart.AddItem("foo", 42, replyTo))
       result1.reply should ===(StatusReply.Success(ShoppingCart.Summary(Map("foo" -> 42))))
       result1.event should ===(ShoppingCart.ItemAdded(cartId, "foo", 42))
     }