                 (->result :max-ops-reached sigs colls t0))
               (->result :converged sigs colls t0))))))))
 
-(defn async-execution-context2
+(defn async-execution-context
   [opts]
   (let [ctx         (merge (default-async-context-opts) opts)
         g           (:graph ctx)

                  (->result :converged i sigs colls t0)))
              (->result :max-iter-reached i sigs colls t0))))))))

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

        s-thresh  (:signal-thresh ctx)
        max-ops   (:max-ops ctx)
        processor ((:processor ctx) s-thresh c-thresh)
        scheduler (:scheduler ctx)
        threads   (:threads ctx)
        watch-id  (keyword (gensym))
        v-filter  (filter #(or (should-signal? % s-thresh) (should-collect? % c-thresh)))
