network-conduit-0.2.1.1: test/main.hs

import Data.Conduit
import Data.Conduit.Network
import Control.Concurrent (forkIO, threadDelay)
import Control.Monad (replicateM_)

main :: IO ()
main = do
    _ <- forkIO $ runTCPServer (ServerSettings 4000 Nothing) echo
    threadDelay 1000
    replicateM_ 10000
        $ runTCPClient (ClientSettings 4000 "localhost") doNothing

echo :: Application
echo src sink = src $$ sink

doNothing :: Application
doNothing _ _ = return ()