diff --git a/src/main/resources/com/github/jlangch/venice/core.venice b/src/main/resources/com/github/jlangch/venice/core.venice index 04f2b743e..16af57490 100644 --- a/src/main/resources/com/github/jlangch/venice/core.venice +++ b/src/main/resources/com/github/jlangch/venice/core.venice @@ -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) @@ -2101,12 +2101,12 @@ tap> [x] (force tap-loop) - (offer! tapq x)) + (offer! tapque x)) ;; --------------------------------------------------------------------------- -;; registered service (service registry) +;; registered services (service registry) ;; --------------------------------------------------------------------------- (defn