haskell/yesod
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

wai-eventsource: Do not Flush needlessly on ioToRepEventSource.

Browse Source
This commit is contained in:
Felipe Lessa 2012-08-20 11:34:50 -03:00
parent e0462b294c
commit 600fec4852
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
yesod-eventsource/Yesod/EventSource.hs
View File

@ -68,10 +68,13 @@ ioToRepEventSource initial act = do
let -- Get new events to be sent. let -- Get new events to be sent.
getEvents s = do getEvents s = do
(evs, s') <- liftIO (act polyfill s) (evs, s') <- liftIO (act polyfill s)
let (builder, continue) = joinEvents evs [] case evs of
C.yield (C.Chunk builder) [] -> getEvents s'
C.yield C.Flush _ -> do
when continue (getEvents s') let (builder, continue) = joinEvents evs []
C.yield (C.Chunk builder)
C.yield C.Flush
when continue (getEvents s')
-- Join all events in a single Builder. Returns @False@ -- Join all events in a single Builder. Returns @False@
-- when we the connection should be closed. -- when we the connection should be closed.