         result (pr-str elt)]
     (.output c result)))
 
-(def to-edn (partial (map-op identity (StringUtf8Coder/of)) to-edn*))
+(def to-edn (partial (map-op identity :to-edn (StringUtf8Coder/of)) to-edn*))
 
 (defn make-pipeline
   [str-args]

  [& args]
  (let [p (make-pipeline args)
        final (->> p
                   (generate-input (range 10000) {:named "gengen"})
                   (dmap inc {:named "map"})
                   (dfilter even? {:named "filter"})
                   (to-edn {:named "edn"})
                   (write-text-file "tee"))]

    (.run p)))

           [datasplash.vals ClojureVal]
           [datasplash.coders ClojureCoder])
  (:gen-class))

(def ops-counter (atom 0))

(defn dofn
  [f & {:keys [start-bundle finish-bundle] :as opts}]
