Skip to content

Commit f066916

Browse files
Alotorniwinz
authored andcommitted
Adds delay-emit operator
1 parent f46b1a4 commit f066916

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/beicon/core.cljs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -708,6 +708,11 @@
708708
[ms ob]
709709
(pipe ob (.delay ^js rxop ms)))
710710

711+
(defn delay-emit
712+
"Time shift the observable but also increase the relative time between emisions."
713+
[ms ob]
714+
(pipe ob (mapcat #(delay ms (of %)))))
715+
711716
(defn delay-when
712717
"Time shifts the observable sequence based on a subscription
713718
delay and a delay selector function for each element."

0 commit comments

Comments
 (0)