-
Notifications
You must be signed in to change notification settings - Fork 3
Expand file tree
/
Copy pathMain.java
More file actions
59 lines (48 loc) · 1.97 KB
/
Main.java
File metadata and controls
59 lines (48 loc) · 1.97 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
import io.reactivex.Observable;
import java.util.Arrays;
import java.util.List;
public class Main {
public static void main( String[] args ) {
onErrorReturn(12);
onErrorResumeNext();
}
/**
* Instruct an Observable to emit a particular item when it encounters an error, and
* then terminate normally.
**/
private static void onErrorReturn(Integer item) {
System.out.println("onErrorReturn");
List<Integer> integerList = Arrays.asList(1, 2, 3);
System.out.println(integerList);
Observable<Integer> integerObservable = Observable.fromIterable(integerList);
System.out.println("onErrorReturn(" + item + ") =====================>");
integerObservable.doAfterNext(integer -> {
if (integer == 3) {
throw new RuntimeException();
}
}).onErrorReturn(throwable -> item)
.subscribe(System.out::println);
System.out.println();
}
/**
* Instruct an Observable to begin emitting a second Observable if it encounters an
* error.
**/
private static void onErrorResumeNext() {
System.out.println("onErrorResumeNext");
List<String> stringList = Arrays.asList("1", "2", "4", "5");
List<String> stringList1 = Arrays.asList("A", "B", "C");
System.out.println(stringList);
System.out.println(stringList1);
Observable<String> stringObservable = Observable.fromIterable(stringList);
Observable<String> stringObservable1 = Observable.fromIterable(stringList1);
System.out.println("onErrorResumeNext =====================>");
stringObservable.doAfterNext(s -> {
if (s.equals("2")) {
throw new RuntimeException();
}
}).onErrorResumeNext(stringObservable1)
.subscribe(System.out::println);
System.out.println();
}
}