gistfile1.clj

(defn transduce-p
  [kf xfs]
  (fn [yield]
    (let [xfs (p/map-vals (fn [xf] (xf yield)) xfs)]
      (fn
        ([] (yield))
        ([result]
           ((reduce comp yield (vals xfs))
            result))
        ([result input]
           (let [key (kf input)
                 trans (get xfs key)]
             (when trans
               (let [result (trans result input)]
                 (if (reduced? result)
                   (deref result)
                   result)))))))))

;; (sequence (transduce-p
;;            even?
;;            {true (take 3)
;;             false (partition-all 2)})
;;           (range 10))
;; => (0 2 [1 3] 4 [5 7] [9])