 %s}")
        (spit path)))
 
-(def g (compute-graph))
-(def ctx
+#_(def g (compute-graph))
+#_(def ctx
   (async-context
    {:graph     g
     :bus-size  64

      _))
  (receive-signal
    [_ src sig]
    (swap! state
           #(-> %
                (update ::uncollected conj sig)
                (assoc-in [::signal-map src] sig)))
    _))

#?(:clj

        [_]
        (stop-execution bus (vertices (:graph ctx)))
        result)
      (notify! [_ evt]
        (go (>! (rand-nth bus) evt)))
      (include-vertex!
        [_ v]
        (processor v _)
        (when (should-collect? v c-thresh)
          (collect! v))
        (when (should-signal? v s-thresh)
          (signal! v))
        _)
      (execute! [_]
        (if-not (realized? result)
          (let [t0 (System/nanoTime)]
            (go
              (run! #(include-vertex! _ %) (vertices (:graph ctx)))
              (loop [colls 0 sigs 0]
                (if (<= (+ colls sigs) max-ops)
                  (let [t (if max-t (timeout max-t))
