       (go-loop [outs @outs]
         (let [[v [f opts]] (first outs)]
           (when v
-            (let [signal (f state opts)]
+            (let [signal (f _ opts)]
               (if-not (nil? signal)
                 (>! (input-channel v) [id signal])
                 (warn (format "signal fn for %d returned nil, skipping..." (:id v)))))

  {:collect-thresh 0
   :signal-thresh  0
   :bus-size       16
   :timeout        100
   :max-ops        1e6})

(defn vertex

(def default-collect (simple-collect into))

(defn signal-forward
  [vertex _] @vertex)

(defn default-score-signal
  "Computes vertex signal score. Returns 0 if state's ::val
