diff --git a/pontarius-xmpp.cabal b/pontarius-xmpp.cabal
--- a/pontarius-xmpp.cabal
+++ b/pontarius-xmpp.cabal
@@ -1,5 +1,5 @@
 Name:          pontarius-xmpp
-Version:       0.4.2.0
+Version:       0.4.2.1
 Cabal-Version: >= 1.9.2
 Build-Type:    Custom
 License:       BSD3
@@ -40,7 +40,7 @@
                , base                 >4 && <5
                , base64-bytestring    >=0.1.0.0
                , binary               >=0.4.1
-               , conduit              >=1.0.1 && < 1.2
+               , conduit              >=1.2.4.2 && < 1.3
                , containers           >=0.4.0.0
                , crypto-api           >=0.9
                , crypto-random        >=0.0.5
diff --git a/source/Network/Xmpp/Stream.hs b/source/Network/Xmpp/Stream.hs
--- a/source/Network/Xmpp/Stream.hs
+++ b/source/Network/Xmpp/Stream.hs
@@ -21,7 +21,7 @@
 import qualified Data.ByteString as BS
 import qualified Data.ByteString.Char8 as BSC8
 import           Data.Char (isSpace)
-import           Data.Conduit
+import           Data.Conduit hiding (connect)
 import qualified Data.Conduit.Internal as DCI
 import qualified Data.Conduit.List as CL
 import           Data.IP
@@ -260,7 +260,7 @@
 bufferSrc :: Source (ErrorT XmppFailure IO) o
           -> IO (ConduitM i o (ErrorT XmppFailure IO) ())
 bufferSrc src = do
-    ref <- newTMVarIO $ DCI.ResumableSource src (return ())
+    ref <- newTMVarIO $ DCI.newResumableSource src
     let go = do
             dt <- liftIO $ Ex.bracketOnError
                       (atomically $ takeTMVar ref)
@@ -281,7 +281,7 @@
                 Right (Just d) -> yield d >> go
     return go
   where
-    zeroResumableSource = DCI.ResumableSource zeroSource (return ())
+    zeroResumableSource = DCI.newResumableSource zeroSource
 
 -- Reads the (partial) stream:stream and the server features from the stream.
 -- Returns the (unvalidated) stream attributes, the unparsed element, or