       (s/end! s)
       (s/end! sv))))
 
-;; ;; - bufferWithTime
-;; ;; - bufferWithCount
-;; ;; - bufferWithTimeOrCount
-;; ;; - toProperty
-
-;; ;; bus
-
 (t/deftest bus-push
   (t/async done
     (let [b (s/bus)]

      (t/is (s/observable? s))
      (drain! s #(t/is (= % coll)))
      (s/on-end s done))))

(t/deftest observable-from-set
  (t/async done

      (s/end! b)
      (s/on-end b done))))

(t/deftest filter-with-predicate
  (t/async done
    (let [s (s/from-coll [1 2 3 4 5])
          fs (s/filter #{3 5} s)]
      (drain! fs #(t/is (= % [3 5])))
      (s/on-end fs done))))

(t/deftest event-stream-as-functor
 (t/async done
