Skip to content

Instantly share code, notes, and snippets.

@anitaa1990
Created August 19, 2018 11:42
Show Gist options
  • Save anitaa1990/1e34a05d936d5c57d2e75e2c7b5930a6 to your computer and use it in GitHub Desktop.
Save anitaa1990/1e34a05d936d5c57d2e75e2c7b5930a6 to your computer and use it in GitHub Desktop.
Observable.just(1, 2, 3, 4, 5)
.reduce(new BiFunction<Integer, Integer, Integer>() {
@Override
public Integer apply(Integer integer, Integer integer2) {
return (integer * integer2);
}
})
.subscribe(new MaybeObserver<Integer>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onSuccess(Integer integer) {
System.out.println("Product of numbers from 1, 2, 3, 4, 5: " + integer);
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment