     (let [s1 (s/from-coll [1 2 3])
           s2 (s/from-coll [:1 :2 :3])
           ms (s/merge s1 s2)]
-      (drain! ms #(t/is (= % [1 :1 2 :2 3 :3])))
+      (drain! ms #(t/is (= % [:1 1 :2 2 :3 3])))
       (s/on-end ms done))))
 
 (t/deftest observable-skip-while

      (drain! ts #(t/is (= % [[1 2] [3 4]])))
      (s/on-end ts done))))

(t/deftest schedulers
  (t/is (s/scheduler? s/asap))
  (t/is (s/scheduler? s/immediate))
  (t/is (s/scheduler? s/queue)))

(t/deftest observe-on
  (t/async done

      (drain! s #(t/is (= % [1 2 3])))
      (s/on-end s done))))

(t/deftest observable-with-timeout
  (t/async done
    (let [s (->> (s/timer 200)
                 (s/timeout 100 (s/just :timeout)))]
      (t/is (s/observable? s))
      (drain! s #(do
                   (t/is (= % [:timeout]))
                   (done))))))

(t/deftest observable-errors-from-binder
