revert KinesisWorkerSourceError back

aserrallerios · Aug 30, 2018 · d2cde96 · d2cde96
1 parent e491980
commit d2cde96
Showing 1 changed file 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,8 +5,11 @@
 package aserralle.akka.stream.kcl
 
 object Errors {
+  sealed class KinesisWorkerSourceError(err: Throwable) extends Throwable(err)
+
   case class WorkerUnexpectedShutdown(cause: Throwable)
-      extends Throwable(cause)
+      extends KinesisWorkerSourceError(cause)
 
-  case class BackpressureTimeout(cause: Throwable) extends Throwable(cause)
+  case class BackpressureTimeout(cause: Throwable)
+      extends KinesisWorkerSourceError(cause)
 }