@Test public void testRepeatTake() { Observable<Integer> xs = Observable.from(1, 2); Object[] ys = xs.repeat(Schedulers.newThread()).take(4).toList().toBlockingObservable().last().toArray(); assertArrayEquals(new Object[] { 1, 2, 1, 2 }, ys); }
public static <T> Observable.OnSubscribeFunc<T> repeat(Observable<T> source, Scheduler scheduler) { return new OperationRepeat<T>(source, scheduler); }
OperationRepeat implements Observable.OnSubscribeFunc<T> { public static <T> Observable.OnSubscribeFunc<T> repeat(Observable<T> source, Scheduler scheduler) { return new OperationRepeat<T>(source, scheduler); } }
OperationRepeat implements Observable.OnSubscribeFunc<T> { public static <T> Observable.OnSubscribeFunc<T> repeat(Observable<T> source, Scheduler scheduler) { return new OperationRepeat<T>(source, scheduler); } private  OperationRepeat(Observable<T> source, Scheduler scheduler); }
OperationRepeat implements Observable.OnSubscribeFunc<T> { public static <T> Observable.OnSubscribeFunc<T> repeat(Observable<T> source, Scheduler scheduler) { return new OperationRepeat<T>(source, scheduler); } private  OperationRepeat(Observable<T> source, Scheduler scheduler); static Observable.OnSubscribeFunc<T> repeat(Observable<T> source, Scheduler scheduler); @Override Subscription onSubscribe(final Observer<? super T> observer); }
OperationRepeat implements Observable.OnSubscribeFunc<T> { public static <T> Observable.OnSubscribeFunc<T> repeat(Observable<T> source, Scheduler scheduler) { return new OperationRepeat<T>(source, scheduler); } private  OperationRepeat(Observable<T> source, Scheduler scheduler); static Observable.OnSubscribeFunc<T> repeat(Observable<T> source, Scheduler scheduler); @Override Subscription onSubscribe(final Observer<? super T> observer);  }