    (fn [_ incoming]
      (let [res (vals (peek incoming))]
        ;;(debug :agg-incoming res)
-       ;; FIXME delay
-       (when (every? #(not= [nil] %) res)
+       (if (every? #(not= [nil] %) res)
          (->> res
               (into #{} (map #(disj % nil)))
               (sort-by count)

              (into #{}
                    (comp (map #(f/vertex-for-id g %))
                          (filter identity)
                          (map deref)))))))))

(defn qvar?
  "Returns true, if x is a qvar (a symbol prefixed with '?')"

  (f/remove-watch! graph :remove-vertex watch-id)
  (close! chan))

(defn make-test-graph
  []
  (let [g (triple-graph (f/compute-graph))
        log (add-triple-graph-logger
