git.iko.soy/typeable/wai
on master help sign in
Moved stuff around a litte
f3c7ee7Mathias Biilmann Christensen
src/Main.hs+7−8
compare with master
unifiedsplit
@@ -15,7 +15,6 @@ import qualified Data.ByteString as B
15import Blaze.ByteString.Builder (fromByteString)
15import Blaze.ByteString.Builder (fromByteString)
16import Blaze.ByteString.Builder.Char.Utf8 (fromString)
16import Blaze.ByteString.Builder.Char.Utf8 (fromString)
17
17
18−
19import EventStream
18import EventStream
20
19
21
20
@@ -32,13 +31,6 @@ res :: Chan ServerEvent -> Response
32res chan = ResponseEnumerator (resE chan)
31res chan = ResponseEnumerator (resE chan)
33
32
34
33
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−
42resE :: Chan ServerEvent -> ResponseEnumerator a
34resE :: Chan ServerEvent -> ResponseEnumerator a
43resE chan genIter =
35resE chan genIter =
44 run_ $ generateM (fmap eventToBuilder $ readChan chan) $$ iter
36 run_ $ generateM (fmap eventToBuilder $ readChan chan) $$ iter
@@ -46,6 +38,13 @@ resE chan genIter =
46 iter = genIter statusOK [("Content-Type", "text/event-stream")]
38 iter = genIter statusOK [("Content-Type", "text/event-stream")]
47
39
48
40
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+
49main :: IO ()
48main :: IO ()
50main = do
49main = do
51 chan <- newChan
50 chan <- newChan