@@ -15,7 +15,6 @@ import qualified Data.ByteString as B
1515import Blaze.ByteString.Builder (fromByteString)
1616import Blaze.ByteString.Builder.Char.Utf8 (fromString)
1717
18−
1918import EventStream
2019
2120
@@ -32,13 +31,6 @@ res :: Chan ServerEvent -> Response
3231res chan = ResponseEnumerator (resE chan)
3332
3433
35−source :: Chan ServerEvent -> IO ()
36−source chan = forever $ do
37− threadDelay 1000000
38− time <- getPOSIXTime
39− writeChan chan (ServerEvent Nothing Nothing [fromString . show $ time])
40−
41−
4234resE :: Chan ServerEvent -> ResponseEnumerator a
4335resE chan genIter =
4436 run_ $ generateM (fmap eventToBuilder $ readChan chan) $$ iter
@@ -46,6 +38,13 @@ resE chan genIter =
4638 iter = genIter statusOK [("Content-Type", "text/event-stream")]
4739
4840
41+source :: Chan ServerEvent -> IO ()
42+source chan = forever $ do
43+ threadDelay 1000000
44+ time <- getPOSIXTime
45+ writeChan chan (ServerEvent Nothing Nothing [fromString . show $ time])
46+
47+
4948main :: IO ()
5049main = do
5150 chan <- newChan