network-conduit-0.6.2.1: test/main.hs

{-# LANGUAGE OverloadedStrings #-}
import Data.Conduit
import Data.Conduit.Network
import Control.Concurrent (forkIO, threadDelay)
import Control.Monad (replicateM_)

main :: IO ()
main = do
    _ <- forkIO $ runTCPServer (serverSettings 4009 "*4") echo
    threadDelay 1000000
    replicateM_ 10000
        $ runTCPClient (clientSettings 4009 "localhost") doNothing

echo :: Application IO
echo ad = appSource ad $$ appSink ad

doNothing :: Application IO
doNothing _ = return ()