demo
public void scan() {Disposable disposable = Observable.just(1, 2, 3, 4, 5).scan(new BiFunction<Integer, Integer, Integer>() {@Overridepublic Integer apply(Integer integer, Integer integer2) throws Exception {System.out.println(" integer================== " + integer);System.out.println(" integer2================== " + integer2);return integer + integer2;}}).subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Exception {System.out.println("========================================accept " + integer);}});
}
public void reduce() {Disposable disposable = Observable.just(1, 2, 3, 4, 5).reduce(new BiFunction<Integer, Integer, Integer>() {@Overridepublic Integer apply(Integer integer, Integer integer2) throws Exception {System.out.println(" integer================== " + integer);System.out.println(" integer2================== " + integer2);return integer + integer2;}}).subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Exception {System.out.println("========================================accept " + integer);}});
}