 ;;                         k (s/from-coll (map (comp keyword str) (range 1 (inc n))))]
 ;;                  (m/return [n k]))
 ;;           sample (s/take 6 snks)]
-;;       (t/is (s/event-stream? snks))
+;;       (t/is (s/observable? snks))
 ;;       (drain! sample #(t/is (= % [[1 :1]
 ;;                                   [2 :1]
 ;;                                   [2 :2]

;;       (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))))
;; ;; ::todo decomplect
;; ;; - filter (pred, property)
;; ;; - map

;;       (drain! b #(t/is (= % [1]))
;;                 #(t/is (= % :oh-no)))
;;       (s/push! b 1)
;;       (s/error! b (ex-info "oh noes" {})
;;       (s/on-error b done))))

;; (t/deftest bus-plug
;;   (t/async done
