Set version to 2021.07.05-1.

Author: niwinz

CHANGES.md

@@ -1,6 +1,19 @@
 # Changelog #
 
-## Version 2021.06-03-0 ##
+## Version 2021.07.05-1 ##
+
+- Fix bug on `delay-emit` operator.
+- Minor change on `concat-reduce` operator.
+
+## Version 2021.07.05-0 ##
+
+- Add `flatten` operator.
+- Add `delay-emit` operator.
+- Add `skip-last` operator.
+- Add `concat-reduce` operator.
+
+
+## Version 2021.06.03-0 ##
 
 BREAKING CHANGES: `zip` no longer accepts acoomulator function.
 

pom.xml

@@ -4,7 +4,7 @@
   <groupId>funcool</groupId>
   <artifactId>beicon</artifactId>
   <packaging>jar</packaging>
-  <version>2021.06.03-0</version>
+  <version>2021.07.05-1</version>
   <name>beicon</name>
   <description>Reactive Streams for Clojure(Script)</description>
   <url>https://github.com/funcool/beicon</url>

src/beicon/core.cljs

@@ -711,7 +711,7 @@
 (defn delay-emit
   "Time shift the observable but also increase the relative time between emisions."
   [ms ob]
-  (pipe ob (mapcat #(delay ms (of %)))))
+  (mapcat #(delay ms (of %)) ob))
 
 (defn delay-when
   "Time shifts the observable sequence based on a subscription
@@ -744,12 +744,12 @@
   value for the next step in the reduce the last valued emited by the stream
   in the function."
   [f seed ob]
-  (let [current-acc (atom seed)]
+  (let [current-acc (volatile! seed)]
     (->> (concat
           (of seed)
           (->> ob
                (mapcat #(f @current-acc %))
-               (tap #(reset! current-acc %))))
+               (tap #(vreset! current-acc %))))
          (last))))
 
 ;; --- Schedulers