diff options
| author | Ben Sima <ben@bsima.me> | 2020-04-11 00:58:03 -0700 |
|---|---|---|
| committer | Ben Sima <ben@bsima.me> | 2020-04-11 01:00:52 -0700 |
| commit | 3c56301c1d18417dba2f7e6cab8a0e543d0f1c9e (patch) | |
| tree | ed23657923eee290d5858926314e757c4fe61d68 /Run/Que/Server.hs | |
| parent | 876d0b1abc63754daba58c60c1ecdc2b4802d3bc (diff) | |
Bound ques to 1 element
Also *really* block on writes.
Diffstat (limited to 'Run/Que/Server.hs')
| -rw-r--r-- | Run/Que/Server.hs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/Run/Que/Server.hs b/Run/Que/Server.hs index 792676d..70bc559 100644 --- a/Run/Que/Server.hs +++ b/Run/Que/Server.hs @@ -147,7 +147,7 @@ routes = do app . modify <| upsertNamespace ns q <- app <| que ns qp qdata <- Scotty.body - liftIO <| Go.write q <| BSL.toStrict qdata + _ <- liftIO <| Go.write q <| BSL.toStrict qdata return () -- | Given `guardNs ns whitelist`, if `ns` is not in the `whitelist` @@ -229,6 +229,6 @@ que ns qp = do if queExists then return <| grab qp qbase else do - c <- liftIO <| Go.chan 5 + c <- liftIO <| Go.chan 1 modify (insertQue ns qp c) gets ques /> grab ns /> grab qp |