    [manifold.deferred :as d]
    [manifold.stream :as s]))
 
-(defn save-to-file [ctx body-stream f]
+;; Works ok
+#_(defn save-to-file [ctx body-stream f]
   (let [fos (new java.io.FileOutputStream f false)
         fc (.getChannel fos)]
     (d/chain

       (.close fc)
       (.close fos)
       (assoc-in ctx [:file] f)))))


        (infof "count is %s" (:count ctx))
        (let [niobuf (b/to-byte-buffer buf)]
          (infof "Writing single buffer %s" (.capacity niobuf))
          (.write fc niobuf))
        
        (update ctx :count (fnil inc 0)))
