Switch usage of Observable.timer for Observable.interval

rwilliams-r7 · Jul 7, 2016 · 4b7c4a1 · 4b7c4a1
1 parent f918595
commit 4b7c4a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...n/java/com/netflix/hystrix/contrib/rxnetty/metricsstream/HystrixMetricsStreamHandler.java b/...n/java/com/netflix/hystrix/contrib/rxnetty/metricsstream/HystrixMetricsStreamHandler.java
@@ -85,7 +85,7 @@ private Observable<Void> handleHystrixRequest(final HttpServerResponse<O> respon
 
         final Subject<Void, Void> subject = PublishSubject.create();
         final MultipleAssignmentSubscription subscription = new MultipleAssignmentSubscription();
-        Subscription actionSubscription = Observable.timer(0, interval, TimeUnit.MILLISECONDS, Schedulers.computation())
+        Subscription actionSubscription = Observable.interval(interval, TimeUnit.MILLISECONDS)
                 .subscribe(new Action1<Long>() {
                     @Override
                     public void call(Long tick) {