               [active sigs (inc colls)])
           [active sigs colls])))))
 
-(defn eager-probabilistic-vertex-processor
+(defn eager-probabilistic-single-pass-processor
   [s-thresh c-thresh]
   (fn [[active sigs colls] v]
     (let [active (conj active v)]

         acc))
     vertices)))

(defn probabilistic-vertex-processor
  [s-thresh c-thresh]
  (fn [[active sigs colls] v]
    (let [active (conj active v)]


(defn parallel-collect-pass
  [thresh]
  (fn [workgroup-size vertices]
    (r/fold
     workgroup-size
     sub-pass-combine
     (fn [acc v]
       (if (should-collect? v thresh)
