haskell/conduit-resumablesink
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

conduit version bump

Browse Source
This commit is contained in:
Ben Foppa 2014-05-26 20:44:22 -04:00
parent 2c1f4d0a67
commit 3e526e5581
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
conduit-resumablesink.cabal
View File

@ -1,5 +1,5 @@
Name: conduit-resumablesink Name: conduit-resumablesink
Version: 0.1.1 Version: 0.1.1.0
Synopsis: Allows conduit to resume sinks to feed multiple sources into it. Synopsis: Allows conduit to resume sinks to feed multiple sources into it.
Description: Description:
@conduit-resumablesink@ is a solution to the problem where you have a @conduit@ @conduit-resumablesink@ is a solution to the problem where you have a @conduit@
@ -20,7 +20,7 @@ Library
Exposed-modules: Data.Conduit.ResumableSink Exposed-modules: Data.Conduit.ResumableSink
Build-depends: Build-depends:
base >= 4 && < 5, base >= 4 && < 5,
conduit >= 1.0.5 && <1.1, conduit >= 1.1 && <1.2,
void >= 0.6 && < 0.7 void >= 0.6 && < 0.7
ghc-options: -Wall ghc-options: -Wall
@ -34,6 +34,7 @@ test-suite test
hspec >= 1.3, hspec >= 1.3,
bytestring, bytestring,
void, void,
resourcet,
transformers transformers
ghc-options: -Wall ghc-options: -Wall

7
test/main.hs
View File

@ -4,16 +4,17 @@ import qualified Data.Conduit.List as C
import Data.Conduit.ResumableSink import Data.Conduit.ResumableSink
import Data.IORef import Data.IORef
import Control.Monad.IO.Class import Control.Monad.IO.Class
import Control.Monad.Trans.Resource as R
main :: IO () main :: IO ()
main = hspec $ describe "use resumable sink" $ do main = hspec $ describe "use resumable sink" $ do
it "behaves like normal conduit when -++$$ used immediately" $ do it "behaves like normal conduit when -++$$ used immediately" $ do
r <- C.runResourceT $ r <- R.runResourceT $
C.sourceList ["hello", "world"] -++$$ newResumableSink C.consume C.sourceList ["hello", "world"] -++$$ newResumableSink C.consume
r `shouldBe` ["hello", "world"] r `shouldBe` ["hello", "world"]
it "sink can be resumed" $ do it "sink can be resumed" $ do
r <- C.runResourceT $ do r <- R.runResourceT $ do
Right r1 <- C.sourceList ["hello", "world"] +$$ C.consume Right r1 <- C.sourceList ["hello", "world"] +$$ C.consume
C.sourceList ["hello", "world"] -++$$ r1 C.sourceList ["hello", "world"] -++$$ r1
r `shouldBe` ["hello", "world", "hello", "world"] r `shouldBe` ["hello", "world", "hello", "world"]
@ -22,7 +23,7 @@ main = hspec $ describe "use resumable sink" $ do
s <- newIORef (0 :: Int, 0 :: Int, 0 :: Int) s <- newIORef (0 :: Int, 0 :: Int, 0 :: Int)
let clean f _ = liftIO $ modifyIORef s f let clean f _ = liftIO $ modifyIORef s f
r <- C.runResourceT $ do r <- R.runResourceT $ do
Right r1 <- Right r1 <-
C.addCleanup (clean incA) (C.sourceList ["hello", "world"]) C.addCleanup (clean incA) (C.sourceList ["hello", "world"])
+$$ C.addCleanup (clean incC) C.consume +$$ C.addCleanup (clean incC) C.consume