Я хотел бы попробовать очень простой код RxJava, например следующий
int[] test = {1,2,3,4};
Observable<Integer> findAverage = Observable.fromArray(test);
averageInteger(findAverage).subscribe(System.out::println);
Сначала я встретил ошибку компиляции (несовместимые границы) для Observeable.fromArray (тест),
Во-вторых, кажется, что severageInteger больше не может быть найден. Я использую версию RxJava 2.0.8.
Integer[] test = {1, 2, 3, 4};
, потому что примитивные массивы не поддерживаются самой RxJava. - person akarnokd   schedule 22.04.2017