This repository contains example of using RxJava with Android to solve real-world problems. More examples will be adding day by day and you are also welcome to contribute.
.combinelatest allows you to monitor the state of multiple observables at a single place. This example demonstrates the use of combinelatest to validate a basic form. In this example there are 3 input fileds for the form. The form will be valid if all those 3 fields are valid. If any input field is invalid, an error message will be shown against invalid input.
We have 3 independent observables that observes the input changes. After an ecent is emited from all 3 inputs, the result is combined and the form is evaluated for validity.
Note that the form will evaluate only after each of those 3 inputs receives at least one event notification or text changes.
This example shows how you can use RxJava's interval and delay operators to a bunch of cases where yo want to run a task at specific time inerval or after a specific time. This a better option than TimerTask. In the exapmle we have used interval operator to log a message after every 2s and delay operator is used for the same purpose but it starts after 10s.
Data binding is a pretty cool thing. It will auto update the view if the data source change. This example demonstrates how we can use PublishSubject to bind data with TextView. Here we have 2 EditText where we can enter two number and 1 TextView to show the sumation of those 2 numbers. The sumation will auto update if we change those numbers. This is a basic use of data binding. You can also use Presentation ViewModel pattern.
Search is a common feature of our daily using apps. It provides the content which we are looking for. We as a developer is responsible to implement in a better way to make it fast. This example will demonstrate how we can implement search feature with RxJava. It use Publish Subject to emit the events when user type to search. Debounce operator is used to execute the search task after a specific interval. Filter operator is used to avoid unknown search like empty search key and DistinctUntilChanged operator to avoid executing search task for the same key. It also use SwitchMap operator to avoid execute search task or network call which are no longer needed to display. Let's assume user is typing "a", "ab", "abc" then Publish Subject will emit event for each key total 3 events. But Debounce operator will wait for time interval then accept events available at that time and will pass it to Filter operator to check either empty or not. As key is changed than before like "ab"->"abc" DistinctUntilChanged operator will pass it to SwitchMap operator to avoid the previous search tesk or network call and process the latest search result.
Now a days, most of the app need to retrieve data from remote server through web service or API. In this example we will get data from a web service and show it in app. As for network library we will use Retrofit. Retrofit will provide the response data as a observable so that we can easily process it.