Merge pull request ReactiveX#356 from jmhofer/interval

Added interval methods to Observable, where they were still missing

Author: benjchristensen

rxjava-core/src/main/java/rx/Observable.java

@@ -37,6 +37,7 @@
 import rx.operators.OperationFilter;
 import rx.operators.OperationFinally;
 import rx.operators.OperationGroupBy;
+import rx.operators.OperationInterval;
 import rx.operators.OperationMap;
 import rx.operators.OperationMaterialize;
 import rx.operators.OperationMerge;
@@ -830,6 +831,35 @@ public static <T> Observable<T> synchronize(Observable<? extends T> observable)
         return create(OperationSynchronize.synchronize(observable));
     }
 
+    
+    /**
+     * Emits an item each time interval (containing a sequential number).
+     * @param interval
+     *            Interval size in time units (see below).
+     * @param unit
+     *            Time units to use for the interval size.
+     * @return An Observable that emits an item each time interval.
+     * @see <a href="http://msdn.microsoft.com/en-us/library/hh229027%28v=vs.103%29.aspx">MSDN: Observable.Interval</a>
+     */
+    public static Observable<Long> interval(long interval, TimeUnit unit) {
+        return create(OperationInterval.interval(interval, unit));
+    }
+    
+    /**
+     * Emits an item each time interval (containing a sequential number).
+     * @param interval
+     *            Interval size in time units (see below).
+     * @param unit
+     *            Time units to use for the interval size.
+     * @param scheduler
+     *            The scheduler to use for scheduling the items.
+     * @return An Observable that emits an item each time interval.
+     * @see <a href="http://msdn.microsoft.com/en-us/library/hh228911%28v=vs.103%29.aspx">MSDN: Observable.Interval</a>
+     */
+    public static Observable<Long> interval(long interval, TimeUnit unit, Scheduler scheduler) {
+        return create(OperationInterval.interval(interval, unit, scheduler));
+    }
+    
     /**
      * Wraps each item emitted by a source Observable in a {@link Timestamped} object.
      * <p>