mirror of https://github.com/logseq/logseq
enhance: add c.m/<? macro
parent
6cea3624ec
commit
d7b85d964b
|
@ -0,0 +1,7 @@
|
||||||
|
(ns frontend.common.missionary-util
|
||||||
|
(:require [missionary.core :as m]))
|
||||||
|
|
||||||
|
(defmacro <?
|
||||||
|
"Like m/?, but async channel as arg"
|
||||||
|
[c]
|
||||||
|
`(m/? (<! ~c)))
|
|
@ -1,5 +1,6 @@
|
||||||
(ns frontend.common.missionary-util
|
(ns frontend.common.missionary-util
|
||||||
"Utils based on missionary."
|
"Utils based on missionary."
|
||||||
|
(:require-macros [frontend.common.missionary-util])
|
||||||
(:require [clojure.core.async :as a]
|
(:require [clojure.core.async :as a]
|
||||||
[missionary.core :as m])
|
[missionary.core :as m])
|
||||||
;; (:import [missionary Cancelled])
|
;; (:import [missionary Cancelled])
|
||||||
|
@ -71,7 +72,6 @@
|
||||||
completing with value when take is accepted, or nil if port was closed."
|
completing with value when take is accepted, or nil if port was closed."
|
||||||
[c] (doto (m/dfv) (->> (a/take! c))))
|
[c] (doto (m/dfv) (->> (a/take! c))))
|
||||||
|
|
||||||
|
|
||||||
(defn await-promise
|
(defn await-promise
|
||||||
"Returns a task completing with the result of given promise"
|
"Returns a task completing with the result of given promise"
|
||||||
[p]
|
[p]
|
||||||
|
|
Loading…
Reference in New Issue