Update deps, changelog and tests.

Author: niwinz

CHANGES.md

@@ -1,5 +1,17 @@
 # Changelog #
 
+## Version 5.0.0 ##
+
+Date: 2019-03-01
+
+- Update to RxJS 6.4.0
+- Update ro RxJava 2.2.7
+
+This release reduces the rxjs bundle size including only the rxjs core
+and all operators (excluding all tests, ajax, websockets and other
+unrelated and not exposted api).
+
+
 ## Version 4.1.0 ##
 
 Date: 2017-11-17

deps.edn

@@ -1,7 +1,7 @@
 {:deps {org.clojure/clojurescript {:mvn/version "1.10.516"}
         org.clojure/clojure {:mvn/version "1.10.0"}
         org.clojure/core.async {:mvn/version "0.3.443"}
-        io.reactivex.rxjava2/rxjava {:mvn/version "2.1.12"}}
+        io.reactivex.rxjava2/rxjava {:mvn/version "2.2.7"}}
  :paths ["src" "assets"]
  :aliases
  {:dev
@@ -18,6 +18,7 @@
    :main-opts ["-m" "hf.depstar.jar"]}
 
   :test
-  {:extra-deps {com.cognitect/test-runner {:git/url "https://github.com/cognitect-labs/test-runner.git"
-                                           :sha "028a6d41ac9ac5d5c405dfc38e4da6b4cc1255d5"}}
-   :main-opts ["-m" "cognitect.test-runner"]}}}
+  {:extra-deps {lambdaisland/kaocha {:mvn/version "0.0-389"}}
+   :main-opts ["-m" "kaocha.runner" "unit"]
+   }}}
+

src/beicon/core.cljc

@@ -279,8 +279,8 @@
                (cond
                  (identical? end v) (.onComplete emitter)
                  (-next? v) (.onNext emitter v)
-                 (-error? v) (.onEr emitter v)
-                 (-end? v) (.onplete emitter)
+                 (-error? v) (.onError emitter v)
+                 (-end? v) (.onComplete emitter)
               (reduced? v) (do
                              (sink emitter @v)
                                 (.onComplete emitter))))]

test/beicon/tests/test_core.cljc

@@ -198,11 +198,14 @@
          (s/on-error s done)))
      :clj
      (let [s (s/create (fn [sink]
-                         (sink (ex-info "oh noes" {}))))]
+                         (future (sink (ex-info "oh noes" {})))))]
        (t/is (s/observable? s))
        (drain! s
-               noop
-               #(t/is (= (ex-message %) "oh noes"))))))
+               (fn [x]
+                 (println "onNext" x))
+               #(do
+                  (println %)
+                  (t/is (= (ex-message %) "oh noes")))))))
 
 (t/deftest observable-from-promise
   #?(:cljs
@@ -262,8 +265,8 @@
        (t/is (s/observable? s))
        (drain! s #(t/is (= % [1]))))))
 
-(t/deftest observable-never
-  #?(:cljs
+#?(:cljs
+   (t/deftest observable-never
      (t/async done
        (let [n (s/never)]
          (s/on-end n done)))))
@@ -298,8 +301,8 @@
            cs (s/zip s1 s2 s3)]
        (drain! cs #(t/is (= % [[1 4 7] [2 5 8]]))))))
 
-(t/deftest observable-fjoin
-  #?(:cljs
+#?(:cljs
+   (t/deftest observable-fjoin
      (t/async done
        (let [s1 (s/from-coll [1 2])
              s2 (s/from-coll [4 5])
@@ -380,8 +383,8 @@
          (s/end! b))
        (drain! b #(t/is (= % [-1 1 2 3]))))))
 
-(t/deftest observable-reduce
-  #?(:cljs
+#?(:cljs
+   (t/deftest observable-reduce
      (t/async done
        (let [s (->> (s/from-coll [4 5 6])
                     (s/reduce conj [1 2])

tests.edn

@@ -0,0 +1,8 @@
+#kaocha/v1
+{:tests [{:id :unit
+          :test-paths ["test/beicon/tests"]
+          :source-paths ["src"]
+          :ns-patterns ["test-"]}]
+ ;; :reporter kaocha.report.progress/progress
+ ;; :plugins [:profiling :notifier]
+ }