   ([source]
    (read! source default-algorithm))
   ([source algorithm]
-   (data/read-block algorithm source)))
+   (io! (data/read-block algorithm source))))
 
 
 (defn write!

   (scan store nil))
  ([store p]
   (->
     (store/-list store nil)
     (cond->>
       p (s/filter p))
     (->>
       (s/reduce sum/update (sum/init))))))


(defn sync!

   (store! store source default-algorithm))
  ([store source algorithm]
   (d/chain
     (io!
       (d/future
         (if (instance? File source)
           (from-file source algorithm)
           (read! source algorithm))))
     (fn put-block
       [block]
       (when block
