Skip to content

Instantly share code, notes, and snippets.

@evandroferreiras

evandroferreiras/rxAndroidExample.java

Created December 16, 2018 01:45
Show Gist options
  • Save evandroferreiras/58e05bb27868986988ff9db857f634e4 to your computer and use it in GitHub Desktop.
Save evandroferreiras/58e05bb27868986988ff9db857f634e4 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
rxAndroidExample.java
Observable<Car> carsObservable = getBestSellingCarsObservable();
carsObservable.subscribeOn(Schedulers.io())
.filter(car -> car.type == Car.Type.ALL_ELECTRIC)
.filter(car -> car.price < 90000)
.map(car -> car.year + " " + car.make + " " + car.model)
.distinct()
.take(5)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(this::updateUi);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment