diff --git a/Data/Conduit/Serialization/Binary.hs b/Data/Conduit/Serialization/Binary.hs
--- a/Data/Conduit/Serialization/Binary.hs
+++ b/Data/Conduit/Serialization/Binary.hs
@@ -15,7 +15,7 @@
 import           Data.Binary
 import           Data.Binary.Get
 import           Data.Binary.Put
-import           Data.ByteString (ByteString)
+-- import           Data.ByteString (ByteString)
 import           Data.ByteString      as BS
 import qualified Data.ByteString.Lazy as LBS
 
@@ -51,15 +51,14 @@
     start = do mx <- await
                case mx of
                   Nothing -> return ()
-                  Just x -> conduit (runGetIncremental g `pushChunk` x)
+                  Just x -> go (runGetIncremental g `pushChunk` x)
     conduit p = await >>= go . flip (maybe pushEndOfInput (flip pushChunk)) p
-        where
-          go (Done bs _ v) = do yield v
-                                if BS.null bs
-                                    then start
-                                    else go (runGetIncremental g `pushChunk` bs)
-          go (Fail u o e)  = monadThrow (ParseError u o e)
-          go (Partial n)   = await >>= (go . n)
+    go (Done bs _ v) = do yield v
+                          if BS.null bs
+                            then start
+                            else go (runGetIncremental g `pushChunk` bs)
+    go (Fail u o e)  = monadThrow (ParseError u o e)
+    go (Partial n)   = await >>= (go . n)
 
 -- | Runs putter repeatedly on a input stream.
 conduitPut :: MonadThrow m => Conduit Put m ByteString
diff --git a/binary-conduit.cabal b/binary-conduit.cabal
--- a/binary-conduit.cabal
+++ b/binary-conduit.cabal
@@ -1,5 +1,5 @@
 name:                binary-conduit
-version:             1.1.0
+version:             1.1.1
 synopsis:            data serialization/deserialization conduit library
 description:         The binary-conduit package.
       Allow binary serialization using iterative conduit interface.