summaryrefslogtreecommitdiff
path: root/Biz/Que
diff options
context:
space:
mode:
Diffstat (limited to 'Biz/Que')
-rw-r--r--Biz/Que/Host.hs22
1 files changed, 11 insertions, 11 deletions
diff --git a/Biz/Que/Host.hs b/Biz/Que/Host.hs
index 79254ad..f1b986c 100644
--- a/Biz/Que/Host.hs
+++ b/Biz/Que/Host.hs
@@ -127,25 +127,25 @@ data Paths path = Paths
dash ::
path
:- "_"
- :> "dash"
- :> Get '[JSON] Ques,
+ :> "dash"
+ :> Get '[JSON] Ques,
getQue ::
path
:- Capture "ns" Text
- :> Capture "quename" Text
- :> Get '[PlainText, HTML, OctetStream] Message,
+ :> Capture "quename" Text
+ :> Get '[PlainText, HTML, OctetStream] Message,
getStream ::
path
:- Capture "ns" Text
- :> Capture "quename" Text
- :> "stream"
- :> StreamGet NoFraming OctetStream (SourceIO Message),
+ :> Capture "quename" Text
+ :> "stream"
+ :> StreamGet NoFraming OctetStream (SourceIO Message),
putQue ::
path
:- Capture "ns" Text
- :> Capture "quepath" Text
- :> ReqBody '[PlainText, HTML, OctetStream] Text
- :> Post '[PlainText, HTML, OctetStream] NoContent
+ :> Capture "quepath" Text
+ :> ReqBody '[PlainText, HTML, OctetStream] Text
+ :> Post '[PlainText, HTML, OctetStream] NoContent
}
deriving (Generic)
@@ -183,7 +183,7 @@ paths _ =
|> str
|> Go.write q
>> Go.read q -- flush the que, otherwise msgs never clear
- |> liftIO
+ |> liftIO
-- TODO: detect number of readers, respond with "sent to N readers" or
-- "no readers, msg lost"
>> pure NoContent