anchor.diff:  
   [source, clojure]
   ----
  -(def bus (s/bus))
  -
  -(s/subscribe bus
  -             #(println "on-value:" %)
  -             #(println "on-error:" %)
  -             #(println "on-end"))
  -
  -(s/end! bus)
  +(def bus (rx/bus))
  +
  +(rx/subscribe bus
  +              #(println "on-value:" %)
  +              #(println "on-error:" %)
  +              #(println "on-end"))
  +
  +(rx/end! bus)
   ;; ==> on-end
   ----
   
  
positive.code: 
  [source, clojure]
  ----
  (def stream (->> (s/from-coll [1 1 1 1 2 3])
                   (s/skip-while odd?)))
  
  (s/subscribe stream
               #(println "on-value:" %)
               #(println "on-error:" %)
               #(println "on-end"))
  
  ;; ==> on-value: 2
  ;; ==> on-value: 3
  
negative.code: 
  [source, clojure]
  ----
  (def sub (rx/on-end sub #(println "end!")))
  ----
  
  === Consume error termination
  