conduintuition.hs

#! /usr/bin/env nix-shell
#! nix-shell -i runghc -p "haskellPackages.ghcWithPackages (ps: [ps.conduit])"

import Conduit

trans :: Monad m => ConduitT Int Int m ()
trans = do
  takeC 3 .| mapC (+ 1)
  takeC 3 .| mapC (* 2)
  xs <- foldlC (\z x -> x : (take 2 z)) []
  yieldMany (reverse xs) .| mapC (* 10)

main :: IO ()
main = runConduit $ yieldMany [1..10]
                 .| trans
                 .| mapM_C print