Clojurians Log v2

Hi, I'm new to missionary and trying to understand the abstractions. I'm working on creating a flow around a JS https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/AsyncGenerator, and using m/observe for it. Does this approach look ok or is there a better way to do it? Also, I'd like for the resulting flow to consume the next iterator lazily, is this possible? thanks

// src/main/starter/asyncgen.js
export async function* abc() {
  yield "a";
  yield "b";
  yield "c";
}

;; src/main/starter/agen.cljs
(ns starter.agen
  (:require [missionary.core :as m]
            ["./asyncgen" :as ag]))

(def >agen 
  (m/observe
   (fn [emit!]
     (let [it (ag/abc)]
       (.then (.next it) (fn handler [item]
                           (let [{:keys [done value]} (js->clj item :keywordize-keys true)]
                             (if done
                               (emit! (reduced :done))
                               (do (emit! value)
                                   (.then (.next it) handler))))))))))


((m/reduce (fn [_ v]
             (if (reduced? v)
               v
               (println :v v)))
           nil >agen)
 #(println :success %) #(println :failure %))
;; => :v a
;; => :v b
;; => :v c
;; => :success :done