🐛 Fix metrics on websocket connections

This commit is contained in:
Andrey Antukh 2022-03-01 14:19:26 +01:00
parent 0534570784
commit 03a082fe40

View file

@ -106,7 +106,7 @@
on-message on-message
(fn [_ message] (fn [_ message]
(mtx/run! metrics {:id :websocket-messages-total :labels ["send"] :inc 1}) (mtx/run! metrics {:id :websocket-messages-total :labels ["recv"] :inc 1})
(try (try
(let [message (t/decode-str message)] (let [message (t/decode-str message)]
(a/offer! input-ch message)) (a/offer! input-ch message))