thelff

{-# OPTIONS -Wall #-}

import Control.Monad (when,forever)
import Control.Monad.Trans
import Control.Monad.Trans.Resource
import qualified Data.ByteString as B
import Data.ByteString (ByteString)
import Data.Conduit
import qualified Data.Conduit.List as CL
import qualified Data.Conduit.Binary as CB

thelff

-- CL.sourceList [1..10] $$ sinkFork' (CL.consume) (CL.isolate 0 =$ CL.consume)
-- ([1],[])
{-# LANGUAGE ScopedTypeVariables #-}
import Data.Conduit
import qualified Data.Conduit.List as CL
import Control.Applicative ((<$>), (<*>), Applicative, pure, (<|>))
import Data.Functor.Identity (runIdentity)
import Debug.Trace

sinkFork :: (Applicative m, Monad m) => Sink a m b -> Sink a m c -> Sink a m (b, c)

thelff

{-# LANGUAGE ScopedTypeVariables #-}
{-# OPTIONS -Wall #-}
import Data.Conduit
import Data.Conduit.Network
import Control.Monad.IO.Class (liftIO)
import Control.Concurrent.Lifted (fork,threadDelay)
import Network (withSocketsDo)
import qualified Control.Exception.Lifted as EL
import Control.Monad.Trans.Resource

thelff

{-# OPTIONS -Wall #-}
import Data.Conduit
import Data.Conduit.Network
import Control.Monad.IO.Class (liftIO)
import Control.Concurrent.Lifted (fork)
import Network (withSocketsDo)

main::IO ()
main =
  liftIO $ withSocketsDo $ runTCPClient (ClientSettings 5000 "127.0.0.1") $ \serverSrc serverSink -> do