      (drain! s2 #(do (t/is (= % [1 2 3]))
                       (done))))))
 
-(t/deftest event-stream-as-applicative
+(t/deftest observable-as-applicative
  (t/async done
    (let [pinc (m/pure s/observable-context inc)
          pval (m/pure s/observable-context 41)

                    (t/is (= % [1 2]))
                    (done))))))

(t/deftest event-stream-as-functor
 (t/async done
   (let [s (s/from-coll [0 1 2])
         s2 (m/fmap inc s)]

     (drain! life #(do (t/is (= % [42]))
                       (done))))))

(t/deftest observable-as-monad
  (t/async done
    (let [sn (s/from-coll [1 2 3])
          snks (m/mlet [n sn
