Clojurians Log v2

I am having issues in consolidating two flows into one. I tried with m/latest m/amb= But I am not able to combine them:

(defn create-random-fill-broker [{:keys [fill-probability wait-seconds] :as opts} order-input-flow] (let [orders (atom {}) fill-flow (m/ap (loop [i 0] (let [fills (create-random-fills fill-probability orders)] (when (seq? fills) (m/amb fills)) (m/? (m/sleep (* 1000 wait-seconds))) (recur (inc i))))) response-flow (m/ap (let [input-msg (m/?> order-input-flow)] (process-incoming-message orders opts input-msg))) output-flow (m/signal (m/latest concat fill-flow response-flow)) broker (random-fill-broker. opts orders order-input-flow output-flow)] broker))```