Observable.from(new Integer[]{1,2,3,4,5})
.reduce(new Func2<Integer, Integer, Integer>() {
@Override
public Integer call(Integer t1, Integer t2) {
return t1+t2;
}
}).subscribe(new Action1<Integer>() {
@Override
public void call(Integer t) {
// t = 15
}
}); |
Observable.from(new Integer[]{1,2,3,4,5})
.reduce(new Func2<Integer, Integer, Integer>() {
@Override
public Integer call(Integer t1, Integer t2) {
return t1+t2;
}
}).subscribe(new Action1<Integer>() {
@Override
public void call(Integer t) {
// t = 15
}
});