-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
43230b0
commit aec56f4
Showing
2 changed files
with
44 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,36 @@ | ||
module Main (main) where | ||
|
||
import Data.Function ((&)) | ||
import Data.Word (Word8) | ||
import Network.Socket (PortNumber) | ||
import Streamly.Data.Stream.Prelude (Stream) | ||
|
||
import qualified Streamly.Console.Stdio as Stdio | ||
import qualified Streamly.Data.Array as Array | ||
import qualified Streamly.Data.Fold as Fold | ||
import qualified Streamly.Data.Stream.Prelude as Stream | ||
import qualified Streamly.Internal.Network.Inet.TCP as TCP | ||
import qualified Streamly.Unicode.Stream as Unicode | ||
|
||
|
||
remoteAddr :: (Word8,Word8,Word8,Word8) | ||
remoteAddr = (127, 0, 0, 1) | ||
|
||
remotePort :: PortNumber | ||
remotePort = 8091 | ||
|
||
echo :: Stream IO () | ||
echo = | ||
Stream.unfold Stdio.reader () -- Stream IO Word8 | ||
& split (== 10) Array.write -- Stream IO (Array Word8) | ||
& TCP.pipeChunks remoteAddr remotePort -- Stream IO (Array Word8) | ||
& Stream.unfoldMany Array.reader -- Stream IO Word8 | ||
& Unicode.decodeLatin1 -- Stream IO Char | ||
& Stream.mapM putChar -- Stream IO () | ||
|
||
where | ||
|
||
split p f = Stream.foldMany (Fold.takeEndBy p f) | ||
|
||
main :: IO () | ||
main = Stream.fold Fold.drain echo |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters