@Test public void testToListReturnsCombinedListOfItems1() { TestObserver<List<String>> observer = new TestObserver<>(); RxUtils.toObservableList(asList(just("1"), just("2"), just("1"), just("2"))) .test() .awaitDone(50, TimeUnit.MILLISECONDS) .assertValue(asList("1", "2", "1", "2")); }
@NonNull public static <T> Observable<List<T>> toObservableList(@NonNull final List<Observable<T>> observables) { return Observable.combineLatest(get(observables), RxUtils::toList); }
RxUtils { @NonNull public static <T> Observable<List<T>> toObservableList(@NonNull final List<Observable<T>> observables) { return Observable.combineLatest(get(observables), RxUtils::toList); } }
RxUtils { @NonNull public static <T> Observable<List<T>> toObservableList(@NonNull final List<Observable<T>> observables) { return Observable.combineLatest(get(observables), RxUtils::toList); } private  RxUtils(); }
RxUtils { @NonNull public static <T> Observable<List<T>> toObservableList(@NonNull final List<Observable<T>> observables) { return Observable.combineLatest(get(observables), RxUtils::toList); } private  RxUtils(); @NonNull static Observable<List<T>> toObservableList(@NonNull final List<Observable<T>> observables); }
RxUtils { @NonNull public static <T> Observable<List<T>> toObservableList(@NonNull final List<Observable<T>> observables) { return Observable.combineLatest(get(observables), RxUtils::toList); } private  RxUtils(); @NonNull static Observable<List<T>> toObservableList(@NonNull final List<Observable<T>> observables);  }