Skip to content

Commit

Permalink
formatting code
Browse files Browse the repository at this point in the history
  • Loading branch information
jlangch committed Mar 29, 2024
1 parent 42773a6 commit f2946b9
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/main/resources/com/github/jlangch/venice/core.venice
Original file line number Diff line number Diff line change
Expand Up @@ -1996,11 +1996,11 @@
;; ---------------------------------------------------------------------------

(defonce ^:private tapset (atom #{}))
(defonce ^:private tapq (queue 1024))
(defonce ^:private tapque (queue 1024))

(defonce ^:private tap-loop
(delay (thread #(loop []
(let [t (take! tapq)]
(let [t (take! tapque)]
(doseq [tap @tapset]
(try
(tap t)
Expand Down Expand Up @@ -2101,12 +2101,12 @@
tap> [x]

(force tap-loop)
(offer! tapq x))
(offer! tapque x))



;; ---------------------------------------------------------------------------
;; registered service (service registry)
;; registered services (service registry)
;; ---------------------------------------------------------------------------

(defn
Expand Down

0 comments on commit f2946b9

Please sign in to comment.