                           {::pp/provides       #{:a}
                            ::pp/response-value {}})})
 
+(defn r-b-dep [env]
+  (let-chan [b (p/entity-attr! env :b)]
+    (+ 10 b)))
+
 (defn r-async [_]
   (go :done))
 
 (def pparser (p/parallel-parser {}))
+
+(defn comparable-trace [trace]
+  (mapv #(dissoc % ::pt/timestamp ::pt/id) trace))
+
+(defn comparable-trace-set [trace]
+  (into #{} (map #(dissoc % ::pt/timestamp ::pt/id)) trace))
 
 (defn quick-reader
   ([reader] (quick-reader {} reader))
   ([env reader] (assoc env ::p/reader [p/map-reader reader])))
 
-(defn comparable-trace [trace]
-  (mapv #(dissoc % ::pt/timestamp ::pt/id) trace))
-
 (defonce trace (atom []))
-
-(comment
-  (comparable-trace @trace))
 
 (deftest test-parallel-parser
   (testing "returns blank channel on response"

(defn r-ab-quick [_]
  {::pp/provides        #{:a :b}
   ::pp/response-stream (go
                          {::pp/provides       #{:a :b}
                           ::pp/response-value {:a 1 :b 2}})})


(ns com.wsscode.pathom.parser-test
  (:require [clojure.test :refer [deftest is testing]]
            [clojure.core.async :as async :refer [go <! <!!]]
            [com.wsscode.common.async-clj :refer [let-chan go-promise]]
            [com.wsscode.pathom.parser :as pp]
            [com.wsscode.pathom.core :as p]
            [com.wsscode.pathom.connect :as pc]
