Skip to content

Commit

Permalink
port to conduit>1.2
Browse files Browse the repository at this point in the history
fixes GH issue pontarius#81
  • Loading branch information
astro committed May 22, 2015
1 parent 6fd9d38 commit f95b5de
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion pontarius-xmpp.cabal
Expand Up @@ -40,7 +40,7 @@ Library
, 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
Expand Down
6 changes: 3 additions & 3 deletions source/Network/Xmpp/Stream.hs
Expand Up @@ -21,7 +21,7 @@ import Data.ByteString (ByteString)
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
Expand Down Expand Up @@ -260,7 +260,7 @@ sourceStreamHandle s = loopRead $ streamReceive s
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)
Expand All @@ -281,7 +281,7 @@ bufferSrc src = do
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
Expand Down

0 comments on commit f95b5de

Please sign in to comment.