 
                   (<!! ack-ch-spy)
                   (<!! status-spy)
+
+                  (extensions/on-change sync (:node/seal nodes) #(>!! seal-spy-a %))
+                  (extensions/touch-node sync (:node/exhaust nodes))
+                  (<!! seal-spy-a)
 
                   (extensions/touch-node sync (:node/completion nodes))
                   (<!! offer-ch-spy))


           (doseq [payload-node payload-nodes]
             (let [payload (extensions/read-node sync payload-node)]
               (extensions/touch-node sync (:node/completion (:nodes payload)))
               (<!! offer-ch-spy)))))


           shutdowns (take n (repeatedly (fn [] (extensions/create sync :shutdown))))
           payloads (take n (repeatedly (fn [] (extensions/create sync :payload))))
           sync-spies (take n (repeatedly (fn [] (chan 1))))
           seal-spies (take n (repeatedly (fn [] (chan 1))))
           
           status-spy (chan (* n 5))
           offer-ch-spy (chan (* n 5))
