   or array/iterable into one observable sequence.
 
   In other languages is called: flatMap or mergeMap."
-  ([ob] (merge-map identity ob))
-  ([f ob] (pipe ob (.flatMap rxop #(f %)))))
+  [f ob]
+  (pipe ob (.flatMap rxop #(f %))))
 
 ;; Aliases
 (def fmap merge-map)

  (pipe ob (.sample rxop other)))

(defn ignore
  "Ignores all elements in an observable sequence leaving
  only the termination messages."
  [ob]
  (pipe ob (.ignoreElements rxop)))

(defn dedupe
  "Returns an observable sequence that contains only

(defn delay-when
  "Time shifts the observable sequence based on a subscription
  delay and a delay selector function for each element."
  ([sf ob] (pipe ob (.delayWhen rxop sf)))
  ([sd sf ob] (pipe ob (.delayWhen rxop sf sd))))

(defn interval
  "Returns an observable sequence that produces a
