format code

aserrallerios · Aug 28, 2018 · e491980 · e491980
1 parent 3edf487
commit e491980
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/main/scala/aserralle/akka/stream/kcl/Errors.scala b/src/main/scala/aserralle/akka/stream/kcl/Errors.scala
@@ -5,7 +5,8 @@
 package aserralle.akka.stream.kcl
 
 object Errors {
-  case class WorkerUnexpectedShutdown(cause: Throwable) extends Throwable(cause)
+  case class WorkerUnexpectedShutdown(cause: Throwable)
+      extends Throwable(cause)
 
   case class BackpressureTimeout(cause: Throwable) extends Throwable(cause)
 }
diff --git a/src/test/scala/aserralle/akka/stream/kcl/KinesisWorkerSourceSourceSpec.scala b/src/test/scala/aserralle/akka/stream/kcl/KinesisWorkerSourceSourceSpec.scala
@@ -202,7 +202,9 @@ class KinesisWorkerSourceSourceSpec
 
       Await.ready(watch, 5.seconds)
       val Failure(exception) = watch.value.get
-      assert(exception.getCause.getMessage.contains("Futures timed out after [100 milliseconds]"))
+      assert(
+        exception.getCause.getMessage
+          .contains("Futures timed out after [100 milliseconds]"))
 
       killSwitch.shutdown()
     }