Hello! question: how can I achieve this with manifold?

(async/go-loop []
  (async/<! (async/timeout 1000))
  (println "tic")
  (recur))

deferred/loop and deferred/let-flow should work i think

in my little experience deferred/loop blocks

I must missing something 🙂

is there an analog manifold construct for async/timeout?

there's deferred/timeout

manifold.stream/consume might be similar too

@vale thank you for your help 🙂

@pbaille cheesy, but

(defn tics [n] (d/chain (d/timeout! (d/deferred) n ::timeout) (fn [_] (prn "tic") (tics n))))

🙂 thank you!