~pepe/neil

0d6226e703861c16a7b961b7bec23c02eacef859 — Josef Pospíšil 2 months ago 0beb185
Remove sse conn log
1 files changed, 3 insertions(+), 7 deletions(-)

M neil/watch/events.janet
M neil/watch/events.janet => neil/watch/events.janet +3 -7
@@ 117,13 117,9 @@
            NotifyStop)))}))

(defn register-chan [chan receiver]
  (make-act
    {:update
     (fn [_ e]
       (update e :events array/push [chan receiver]))
     :watch
     (fn [_ e _]
       (log (format-now) " Events count: " (length (e :events))))}
  (make-update
    (fn [_ e]
      (update e :events array/push [chan receiver]))
    "register-chan"))

(defn deregister-chan [chan]