2: Router: no multiline tokens in select chains

kitbellew · Jun 8, 2020 · bbf3b98 · bbf3b98
1 parent 8230793
commit bbf3b98
Show file tree

Hide file tree

Showing 30 changed files with 244 additions and 136 deletions.
diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/event/LoggerSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/event/LoggerSpec.scala
@@ -19,32 +19,35 @@ import akka.event.Logging.Warning
 
 object LoggerSpec {
 
-  val defaultConfig =
-    ConfigFactory.parseString("""
+  val defaultConfig = ConfigFactory
+    .parseString("""
       akka {
         stdout-loglevel = "WARNING"
         loglevel = "DEBUG"
         loggers = ["akka.event.LoggerSpec$TestLogger1"]
       }
-    """).withFallback(AkkaSpec.testConf)
+    """)
+    .withFallback(AkkaSpec.testConf)
 
-  val slowConfig =
-    ConfigFactory.parseString("""
+  val slowConfig = ConfigFactory
+    .parseString("""
       akka {
         stdout-loglevel = "ERROR"
         loglevel = "ERROR"
         loggers = ["akka.event.LoggerSpec$SlowLogger"]
       }
-    """).withFallback(AkkaSpec.testConf)
+    """)
+    .withFallback(AkkaSpec.testConf)
 
-  val noLoggingConfig =
-    ConfigFactory.parseString("""
+  val noLoggingConfig = ConfigFactory
+    .parseString("""
       akka {
         stdout-loglevel = "OFF"
         loglevel = "OFF"
         loggers = ["akka.event.LoggerSpec$TestLogger1"]
       }
-    """).withFallback(AkkaSpec.testConf)
+    """)
+    .withFallback(AkkaSpec.testConf)
 
   val multipleConfig = ConfigFactory
     .parseString(
@@ -57,8 +60,8 @@ object LoggerSpec {
     """)
     .withFallback(AkkaSpec.testConf)
 
-  val ticket3165Config =
-    ConfigFactory.parseString("""
+  val ticket3165Config = ConfigFactory
+    .parseString("""
       akka {
         stdout-loglevel = "WARNING"
         loglevel = "DEBUG"
@@ -71,10 +74,11 @@ object LoggerSpec {
           }
         }
       }
-    """).withFallback(AkkaSpec.testConf)
+    """)
+    .withFallback(AkkaSpec.testConf)
 
-  val ticket3671Config =
-    ConfigFactory.parseString("""
+  val ticket3671Config = ConfigFactory
+    .parseString("""
       akka {
         stdout-loglevel = "WARNING"
         loglevel = "WARNING"
@@ -83,7 +87,8 @@ object LoggerSpec {
           serialize-messages = off
         }
       }
-    """).withFallback(AkkaSpec.testConf)
+    """)
+    .withFallback(AkkaSpec.testConf)
 
   final case class SetTarget(ref: ActorRef, qualifier: Int)
 

diff --git a/repos/akka/akka-bench-jmh/src/main/scala/akka/http/HttpBenchmark.scala b/repos/akka/akka-bench-jmh/src/main/scala/akka/http/HttpBenchmark.scala
@@ -24,10 +24,12 @@ import com.typesafe.config.ConfigFactory
 @BenchmarkMode(Array(Mode.Throughput))
 class HttpBenchmark {
 
-  val config = ConfigFactory.parseString("""
+  val config = ConfigFactory
+    .parseString("""
       akka {
         loglevel = "ERROR"
-      }""".stripMargin).withFallback(ConfigFactory.load())
+      }""".stripMargin)
+    .withFallback(ConfigFactory.load())
 
   implicit val system = ActorSystem("HttpBenchmark", config)
   implicit val materializer = ActorMaterializer()

diff --git a/repos/akka/akka-camel/src/test/scala/akka/camel/internal/component/ActorProducerTest.scala b/repos/akka/akka-camel/src/test/scala/akka/camel/internal/component/ActorProducerTest.scala
@@ -382,7 +382,8 @@ private[camel] trait ActorProducerFixture
         override lazy val template = mock[ProducerTemplate]
         override lazy val context = mock[DefaultCamelContext]
         override val settings = new CamelSettings(
-          ConfigFactory.parseString("""
+          ConfigFactory
+            .parseString("""
           akka {
             camel {
               jmx = off
@@ -394,7 +395,8 @@ private[camel] trait ActorProducerFixture
               }
             }
           }
-        """).withFallback(config),
+        """)
+            .withFallback(config),
           sys.dynamicAccess)
       }
     camel = camelWithMocks

diff --git a/repos/akka/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode2Spec.scala b/repos/akka/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode2Spec.scala
@@ -57,10 +57,12 @@ abstract class RestartNode2SpecSpec
   // this is the node that will attempt to re-join, keep gate times low so it can retry quickly
   lazy val restartedSeed1System = ActorSystem(
     system.name,
-    ConfigFactory.parseString(s"""
+    ConfigFactory
+      .parseString(s"""
       akka.remote.netty.tcp.port= ${seedNodes.head.port.get}
       #akka.remote.retry-gate-closed-for = 1s
-    """).withFallback(system.settings.config)
+    """)
+      .withFallback(system.settings.config)
   )
 
   override def afterAll(): Unit = {

diff --git a/repos/akka/akka-cluster/src/multi-jvm/scala/akka/cluster/UnreachableNodeJoinsAgainSpec.scala b/repos/akka/akka-cluster/src/multi-jvm/scala/akka/cluster/UnreachableNodeJoinsAgainSpec.scala
@@ -180,12 +180,14 @@ abstract class UnreachableNodeJoinsAgainSpec
         // create new ActorSystem with same host:port
         val freshSystem = ActorSystem(
           system.name,
-          ConfigFactory.parseString(s"""
+          ConfigFactory
+            .parseString(s"""
             akka.remote.netty.tcp {
               hostname = ${victimAddress.host.get}
               port = ${victimAddress.port.get}
             }
-            """).withFallback(system.settings.config)
+            """)
+            .withFallback(system.settings.config)
         )
 
         try {

diff --git a/...cluster/src/multi-jvm/scala/akka/cluster/routing/ClusterConsistentHashingRouterSpec.scala b/...cluster/src/multi-jvm/scala/akka/cluster/routing/ClusterConsistentHashingRouterSpec.scala
@@ -37,7 +37,8 @@ object ClusterConsistentHashingRouterMultiJvmSpec extends MultiNodeConfig {
   val third = role("third")
 
   commonConfig(
-    debugConfig(on = false).withFallback(ConfigFactory.parseString(s"""
+    debugConfig(on = false)
+      .withFallback(ConfigFactory.parseString(s"""
       common-router-settings = {
         router = consistent-hashing-pool
         cluster {
@@ -52,7 +53,8 @@ object ClusterConsistentHashingRouterMultiJvmSpec extends MultiNodeConfig {
         /router3 = $${common-router-settings}
         /router4 = $${common-router-settings}
       }
-      """)).withFallback(MultiNodeClusterSpec.clusterConfig))
+      """))
+      .withFallback(MultiNodeClusterSpec.clusterConfig))
 
 }
 

diff --git a/...kka/akka-persistence/src/test/scala/akka/persistence/journal/InmemEventAdaptersSpec.scala b/...kka/akka-persistence/src/test/scala/akka/persistence/journal/InmemEventAdaptersSpec.scala
@@ -10,7 +10,8 @@ import com.typesafe.config.ConfigFactory
 
 class InmemEventAdaptersSpec extends AkkaSpec {
 
-  val config = ConfigFactory.parseString(s"""
+  val config = ConfigFactory
+    .parseString(s"""
       |akka.persistence.journal {
       |  plugin = "akka.persistence.journal.inmem"
       |
@@ -38,7 +39,8 @@ class InmemEventAdaptersSpec extends AkkaSpec {
       |    }
       |  }
       |}
-    """.stripMargin).withFallback(ConfigFactory.load())
+    """.stripMargin)
+    .withFallback(ConfigFactory.load())
 
   val extendedActorSystem = system.asInstanceOf[ExtendedActorSystem]
   val inmemConfig = config.getConfig("akka.persistence.journal.inmem")

diff --git a/...a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartDeathWatchSpec.scala b/...a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartDeathWatchSpec.scala
@@ -111,12 +111,14 @@ abstract class RemoteNodeRestartDeathWatchSpec
 
         val freshSystem = ActorSystem(
           system.name,
-          ConfigFactory.parseString(s"""
+          ConfigFactory
+            .parseString(s"""
                     akka.remote.netty.tcp {
                       hostname = ${addr.host.get}
                       port = ${addr.port.get}
                     }
-                    """).withFallback(system.settings.config)
+                    """)
+            .withFallback(system.settings.config)
         )
         freshSystem.actorOf(Props[Subject], "subject")
 

diff --git a/repos/akka/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartGateSpec.scala b/repos/akka/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartGateSpec.scala
@@ -115,13 +115,15 @@ abstract class RemoteNodeRestartGateSpec
 
         val freshSystem = ActorSystem(
           system.name,
-          ConfigFactory.parseString(s"""
+          ConfigFactory
+            .parseString(s"""
                     akka.remote.retry-gate-closed-for = 0.5 s
                     akka.remote.netty.tcp {
                       hostname = ${addr.host.get}
                       port = ${addr.port.get}
                     }
-                    """).withFallback(system.settings.config)
+                    """)
+            .withFallback(system.settings.config)
         )
 
         val probe = TestProbe()(freshSystem)

diff --git a/...kka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeShutdownAndComesBackSpec.scala b/...kka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeShutdownAndComesBackSpec.scala
@@ -150,12 +150,14 @@ abstract class RemoteNodeShutdownAndComesBackSpec
 
         val freshSystem = ActorSystem(
           system.name,
-          ConfigFactory.parseString(s"""
+          ConfigFactory
+            .parseString(s"""
                     akka.remote.netty.tcp {
                       hostname = ${addr.host.get}
                       port = ${addr.port.get}
                     }
-                    """).withFallback(system.settings.config)
+                    """)
+            .withFallback(system.settings.config)
         )
         freshSystem.actorOf(Props[Subject], "subject")
 

diff --git a/...akka/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteQuarantinePiercingSpec.scala b/...akka/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteQuarantinePiercingSpec.scala
@@ -114,12 +114,14 @@ abstract class RemoteQuarantinePiercingSpec
 
         val freshSystem = ActorSystem(
           system.name,
-          ConfigFactory.parseString(s"""
+          ConfigFactory
+            .parseString(s"""
                     akka.remote.netty.tcp {
                       hostname = ${addr.host.get}
                       port = ${addr.port.get}
                     }
-                    """).withFallback(system.settings.config)
+                    """)
+            .withFallback(system.settings.config)
         )
         freshSystem.actorOf(Props[Subject], "subject")
 

diff --git a/...ka/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteRestartedQuarantinedSpec.scala b/...ka/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteRestartedQuarantinedSpec.scala
@@ -144,13 +144,15 @@ abstract class RemoteRestartedQuarantinedSpec
 
         val freshSystem = ActorSystem(
           system.name,
-          ConfigFactory.parseString(s"""
+          ConfigFactory
+            .parseString(s"""
                     akka.remote.retry-gate-closed-for = 0.5 s
                     akka.remote.netty.tcp {
                       hostname = ${addr.host.get}
                       port = ${addr.port.get}
                     }
-                    """).withFallback(system.settings.config)
+                    """)
+            .withFallback(system.settings.config)
         )
 
         val probe = TestProbe()(freshSystem)

diff --git a/repos/akka/akka-remote/src/test/scala/akka/remote/RemoteInitErrorSpec.scala b/repos/akka/akka-remote/src/test/scala/akka/remote/RemoteInitErrorSpec.scala
@@ -21,8 +21,8 @@ import scala.util.control.NonFatal
   */
 @org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
 class RemoteInitErrorSpec extends FlatSpec with Matchers {
-  val conf =
-    ConfigFactory.parseString("""
+  val conf = ConfigFactory
+    .parseString("""
       akka {
         actor {
           provider = "akka.remote.RemoteActorRefProvider"
@@ -35,7 +35,8 @@ class RemoteInitErrorSpec extends FlatSpec with Matchers {
             }
         }
       }
-    """).resolve()
+    """)
+    .resolve()
 
   def currentThreadIds(): Set[Long] = {
     val threads = Thread.getAllStackTraces().keySet()

diff --git a/repos/akka/akka-remote/src/test/scala/akka/remote/RemoteRouterSpec.scala b/repos/akka/akka-remote/src/test/scala/akka/remote/RemoteRouterSpec.scala
@@ -37,7 +37,8 @@ class RemoteRouterSpec
   val port =
     system.asInstanceOf[ExtendedActorSystem].provider.getDefaultAddress.port.get
   val sysName = system.name
-  val conf = ConfigFactory.parseString(s"""
+  val conf = ConfigFactory
+    .parseString(s"""
     akka {
       actor.deployment {
         /blub {
@@ -70,7 +71,8 @@ class RemoteRouterSpec
           target.nodes = ["akka.tcp://${sysName}@localhost:${port}"]
         }
       }
-    }""").withFallback(system.settings.config)
+    }""")
+    .withFallback(system.settings.config)
   val masterSystem = ActorSystem("Master" + sysName, conf)
 
   override def afterTermination() {