|
1 | 1 | package com.rxjava2.android.samples.ui.networking;
|
2 | 2 |
|
3 | 3 | import android.os.Bundle;
|
4 |
| -import android.support.v7.app.AppCompatActivity; |
5 | 4 | import android.util.Log;
|
6 | 5 | import android.util.Pair;
|
7 | 6 | import android.view.View;
|
|
16 | 15 | import java.util.ArrayList;
|
17 | 16 | import java.util.List;
|
18 | 17 |
|
| 18 | +import androidx.appcompat.app.AppCompatActivity; |
19 | 19 | import io.reactivex.Observable;
|
20 | 20 | import io.reactivex.ObservableSource;
|
21 | 21 | import io.reactivex.Observer;
|
@@ -52,7 +52,7 @@ public void map(View view) {
|
52 | 52 | .observeOn(AndroidSchedulers.mainThread())
|
53 | 53 | .map(new Function<ApiUser, User>() {
|
54 | 54 | @Override
|
55 |
| - public User apply(ApiUser apiUser) throws Exception { |
| 55 | + public User apply(ApiUser apiUser) { |
56 | 56 | // here we get ApiUser from server
|
57 | 57 | User user = new User(apiUser);
|
58 | 58 | // then by converting, we are returning user
|
@@ -115,7 +115,7 @@ private void findUsersWhoLovesBoth() {
|
115 | 115 | Observable.zip(getCricketFansObservable(), getFootballFansObservable(),
|
116 | 116 | new BiFunction<List<User>, List<User>, List<User>>() {
|
117 | 117 | @Override
|
118 |
| - public List<User> apply(List<User> cricketFans, List<User> footballFans) throws Exception { |
| 118 | + public List<User> apply(List<User> cricketFans, List<User> footballFans) { |
119 | 119 | List<User> userWhoLovesBoth =
|
120 | 120 | filterUserWhoLovesBoth(cricketFans, footballFans);
|
121 | 121 | return userWhoLovesBoth;
|
@@ -183,13 +183,13 @@ public void flatMapAndFilter(View view) {
|
183 | 183 | getAllMyFriendsObservable()
|
184 | 184 | .flatMap(new Function<List<User>, ObservableSource<User>>() { // flatMap - to return users one by one
|
185 | 185 | @Override
|
186 |
| - public ObservableSource<User> apply(List<User> usersList) throws Exception { |
| 186 | + public ObservableSource<User> apply(List<User> usersList) { |
187 | 187 | return Observable.fromIterable(usersList); // returning user one by one from usersList.
|
188 | 188 | }
|
189 | 189 | })
|
190 | 190 | .filter(new Predicate<User>() {
|
191 | 191 | @Override
|
192 |
| - public boolean test(User user) throws Exception { |
| 192 | + public boolean test(User user) { |
193 | 193 | // filtering user who follows me.
|
194 | 194 | return user.isFollowing;
|
195 | 195 | }
|
@@ -229,7 +229,7 @@ public void take(View view) {
|
229 | 229 | getUserListObservable()
|
230 | 230 | .flatMap(new Function<List<User>, ObservableSource<User>>() { // flatMap - to return users one by one
|
231 | 231 | @Override
|
232 |
| - public ObservableSource<User> apply(List<User> usersList) throws Exception { |
| 232 | + public ObservableSource<User> apply(List<User> usersList) { |
233 | 233 | return Observable.fromIterable(usersList); // returning user one by one from usersList.
|
234 | 234 | }
|
235 | 235 | })
|
@@ -269,13 +269,13 @@ public void flatMap(View view) {
|
269 | 269 | getUserListObservable()
|
270 | 270 | .flatMap(new Function<List<User>, ObservableSource<User>>() { // flatMap - to return users one by one
|
271 | 271 | @Override
|
272 |
| - public ObservableSource<User> apply(List<User> usersList) throws Exception { |
| 272 | + public ObservableSource<User> apply(List<User> usersList) { |
273 | 273 | return Observable.fromIterable(usersList); // returning user one by one from usersList.
|
274 | 274 | }
|
275 | 275 | })
|
276 | 276 | .flatMap(new Function<User, ObservableSource<UserDetail>>() {
|
277 | 277 | @Override
|
278 |
| - public ObservableSource<UserDetail> apply(User user) throws Exception { |
| 278 | + public ObservableSource<UserDetail> apply(User user) { |
279 | 279 | // here we get the user one by one
|
280 | 280 | // and returns corresponding getUserDetailObservable
|
281 | 281 | // for that userId
|
@@ -331,21 +331,21 @@ public void flatMapWithZip(View view) {
|
331 | 331 | getUserListObservable()
|
332 | 332 | .flatMap(new Function<List<User>, ObservableSource<User>>() { // flatMap - to return users one by one
|
333 | 333 | @Override
|
334 |
| - public ObservableSource<User> apply(List<User> usersList) throws Exception { |
| 334 | + public ObservableSource<User> apply(List<User> usersList) { |
335 | 335 | return Observable.fromIterable(usersList); // returning user one by one from usersList.
|
336 | 336 | }
|
337 | 337 | })
|
338 | 338 | .flatMap(new Function<User, ObservableSource<Pair<UserDetail, User>>>() {
|
339 | 339 | @Override
|
340 |
| - public ObservableSource<Pair<UserDetail, User>> apply(User user) throws Exception { |
| 340 | + public ObservableSource<Pair<UserDetail, User>> apply(User user) { |
341 | 341 | // here we get the user one by one and then we are zipping
|
342 | 342 | // two observable - one getUserDetailObservable (network call to get userDetail)
|
343 | 343 | // and another Observable.just(user) - just to emit user
|
344 | 344 | return Observable.zip(getUserDetailObservable(user.id),
|
345 | 345 | Observable.just(user),
|
346 | 346 | new BiFunction<UserDetail, User, Pair<UserDetail, User>>() {
|
347 | 347 | @Override
|
348 |
| - public Pair<UserDetail, User> apply(UserDetail userDetail, User user) throws Exception { |
| 348 | + public Pair<UserDetail, User> apply(UserDetail userDetail, User user) { |
349 | 349 | // runs when network call completes
|
350 | 350 | // we get here userDetail for the corresponding user
|
351 | 351 | return new Pair<>(userDetail, user); // returning the pair(userDetail, user)
|
|
0 commit comments