Skip to content

Instantly share code, notes, and snippets.

@selmanon
Created September 19, 2018 09:50
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save selmanon/10bfaec9cbeedf63d5dbc344506c4e90 to your computer and use it in GitHub Desktop.
Save selmanon/10bfaec9cbeedf63d5dbc344506c4e90 to your computer and use it in GitHub Desktop.
Observable
.just(1, 2, 3, 4, 5)
.filter(new Func1<Integer, Boolean>() {
@Override
public Boolean call(Integer integer) {
return integer % 2 != 0;
}
}).subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Integer integer) {
Log.i(TAG, String.valueOf(integer));
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "Error");
}
@Override
public void onComplete() {
Log.i(TAG, "No more results");
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment