@@ -11,9 +11,9 @@ import qualified Streamly.Prelude as S
11main :: IO ()
11main :: IO ()
12main = S.drain
12main = S.drain
13 $ parallely $ S.mapM (useWith echo)
13 $ parallely $ S.mapM (useWith echo)
14− $ serially $ S.unfold TCP.acceptOnPort 8090
14+ $ serially $ S.unfold TCP.acceptOnPort 8091
17 S.fold (writeChunks sk)
17 S.fold (writeChunks sk)
18 $ S.unfold readChunksWithBufferOf (32768, sk)
18 $ S.unfold readChunksWithBufferOf (32768, sk)
19− useWith f sk = finally (liftIO (Net.close sk)) (f sk)
19+ useWith f sk = finally (f sk) (liftIO (Net.close sk))