From d2cde96742285d12478e75a0a43a81eb1ff8f434 Mon Sep 17 00:00:00 2001
From: Chiyu Zhong <zhongchiyu@gmail.com>
Date: Thu, 30 Aug 2018 16:56:19 +0800
Subject: [PATCH] revert KinesisWorkerSourceError back

---
 src/main/scala/aserralle/akka/stream/kcl/Errors.scala | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/main/scala/aserralle/akka/stream/kcl/Errors.scala b/src/main/scala/aserralle/akka/stream/kcl/Errors.scala
index 50036a8..c64c083 100644
--- 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)
 }