@Test public void testNoStackOverFlow() { Observable.from(1).repeat(Schedulers.newThread()).take(100000).toBlockingObservable().last(); }
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);  }