🐛 Fix invalid return value on worker api when worker is not available

Mainly happens on tests
This commit is contained in:
Andrey Antukh 2024-11-12 10:50:24 +01:00 committed by Andrés Moya
parent 44ffdc4f97
commit c05a69509e

View file

@ -8,7 +8,8 @@
(:require (:require
[app.config :as cf] [app.config :as cf]
[app.main.errors :as err] [app.main.errors :as err]
[app.util.worker :as uw])) [app.util.worker :as uw]
[beicon.v2.core :as rx]))
(defonce instance nil) (defonce instance nil)
@ -22,18 +23,30 @@
(defn ask! (defn ask!
([message] ([message]
(when instance (uw/ask! instance message))) (if instance
(uw/ask! instance message)
(rx/empty)))
([message transfer] ([message transfer]
(when instance (uw/ask! instance message transfer)))) (if instance
(uw/ask! instance message transfer)
(rx/empty))))
(defn ask-buffered! (defn ask-buffered!
([message] ([message]
(when instance (uw/ask-buffered! instance message))) (if instance
(uw/ask-buffered! instance message)
(rx/empty)))
([message transfer] ([message transfer]
(when instance (uw/ask-buffered! instance message transfer)))) (if instance
(uw/ask-buffered! instance message transfer)
(rx/empty))))
(defn ask-many! (defn ask-many!
([message] ([message]
(when instance (uw/ask-many! instance message))) (if instance
(uw/ask-many! instance message)
(rx/empty)))
([message transfer] ([message transfer]
(when instance (uw/ask-many! instance message transfer)))) (if instance
(uw/ask-many! instance message transfer)
(rx/empty))))