diff options
| -rw-r--r-- | Que/Server.hs | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/Que/Server.hs b/Que/Server.hs index 9e8d893..5287c02 100644 --- a/Que/Server.hs +++ b/Que/Server.hs @@ -186,12 +186,11 @@ guardNs ns whitelist = when (not <| ns `elem` whitelist) <| do -- | Forever write the data from 'Que' to 'Wai.StreamingBody'. streamQue :: Que -> Wai.StreamingBody -streamQue q write _ = Go.mult q >>= loop +streamQue q write _ = loop q where loop c = - Go.tap c + Go.read c >>= (write . Builder.byteStringInsert) - >> (write <| Builder.byteStringInsert "\n") >> loop c -- | Gets the thing from the Hashmap. Call's 'error' if key doesn't exist. |