Skip to content

Instantly share code, notes, and snippets.

@anitaa1990
Created August 19, 2018 10:28
Show Gist options
  • Save anitaa1990/e49aadf468915d7361e91c531b4dbbaf to your computer and use it in GitHub Desktop.
Save anitaa1990/e49aadf468915d7361e91c531b4dbbaf to your computer and use it in GitHub Desktop.
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> emitter) {
int num = (int) (Math.random() * 10);
if (num % 2 == 0) {
emitter.onNext(num);
}
emitter.onComplete();
}
})
.defaultIfEmpty(-10)
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Integer integer) {
System.out.println("onNext: " + 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