s/observeOne/observeOn

simonhoo · Jan 20, 2015 · 00aa1d3 · 00aa1d3
1 parent 27fcc4a
commit 00aa1d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hystrix-contrib/hystrix-clj/src/main/clojure/com/netflix/hystrix/core.clj b/hystrix-contrib/hystrix-clj/src/main/clojure/com/netflix/hystrix/core.clj
@@ -637,7 +637,7 @@
     (observe-later-on* [this scheduler] (.observeOn (.toObservable this) scheduler))
   HystrixCollapser
     (observe-later* [this] (.toObservable this))
-    (observe-later-on* [this scheduler] (.observeOne (.toObservable this) scheduler)))
+    (observe-later-on* [this scheduler] (.observeOn (.toObservable this) scheduler)))
 
 (defn observe-later
   "Same as #'com.netflix.hystrix.core/observe, but command execution does not begin until the