 
 (defn index-vertex
   [g spo]
-  (add-vertex! g {::val {}
-                  ::collect-fn (collect-index spo)
-                  ::score-signal-fn (constantly 1)}))
+  (add-vertex!
+   g {::val             {}
+      ::collect-fn      (collect-index spo)
+      ::score-signal-fn (constantly 1)}))
 
 (def s-idx (index-vertex g 0))
 (def p-idx (index-vertex g 1))

     [fabric type project]
     [toxi type person]]))

(def ctx (async-context {:graph g :processor eager-vertex-processor :timeout nil}))
(def toxi (register-query g 'toxi nil nil))
(def types (register-query g nil 'type nil))
(def projects (register-query g nil 'type 'project))

(execute! ctx)

;;(warn :free-ram (.freeMemory (Runtime/getRuntime)))

    (signal! v)
    v))

(defn add-counter
  [g src]
  (let [v (add-vertex!
           g {::collect-fn
              (simple-collect
               (fn [val in]
                 (info :updated-result (pr-str (peek in)))
                 (count (peek in))))})]
    (connect-to! src v signal-forward nil)
    v))

(defn signal-select
  [vertex [idx sel]]
  [idx (if sel (@vertex sel [nil]) (->> @vertex vals (eduction (mapcat identity))))])
