git.iko.soy/streamly
on 7a232eb help sign in
streamly/examples/FromFileClient.hs
11 lines 401 B history raw
1import Streamly
2import qualified Streamly.Prelude as S
3import Streamly.Network.Socket
4import qualified Streamly.Mem.Array as A
5import qualified Streamly.Fold as FL
7main :: IO ()
8main = S.drain $ parallely
9 -- $ S.mapM (\sk -> writeArrays sk $ readArrays sk)
10 $ S.mapM (\sk -> S.mapM_ print $ FL.sessionsOf 10 FL.sum $ S.map A.length $ readArrays sk)
11 $ serially $ fmap fst (serveTCPOn 8090)