diff options
Diffstat (limited to 'Omni/Jr')
| -rw-r--r-- | Omni/Jr/Web.hs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/Omni/Jr/Web.hs b/Omni/Jr/Web.hs index 2be8ea1..d528365 100644 --- a/Omni/Jr/Web.hs +++ b/Omni/Jr/Web.hs @@ -19,6 +19,7 @@ where import Alpha import qualified Control.Concurrent as Concurrent import qualified Data.Aeson as Aeson +import qualified Data.ByteString.Lazy as LBS import qualified Data.List as List import qualified Data.Text as Text import qualified Data.Text.Lazy as LazyText @@ -261,7 +262,7 @@ instance Accept SSE where contentType _ = "text/event-stream" instance MimeRender SSE ByteString where - mimeRender _ = identity + mimeRender _ = LBS.fromStrict data HomePage = HomePage TaskCore.TaskStats [TaskCore.Task] [TaskCore.Task] Bool TaskCore.AggregatedMetrics TimeRange UTCTime @@ -2576,7 +2577,7 @@ streamAgentEvents tid sid = do streamEventsStep :: Text -> Text -> Int -> [ByteString] -> Bool -> Source.StepT IO ByteString streamEventsStep tid sid lastId buffer sendExisting = case (sendExisting, buffer) of -- Send buffered existing events first - (True, b : bs) -> pure <| Source.Yield b (streamEventsStep tid sid lastId bs True) + (True, b : bs) -> Source.Yield b (streamEventsStep tid sid lastId bs True) (True, []) -> streamEventsStep tid sid lastId [] False -- Poll for new events (False, _) -> |