FilesExpand file tree

master

/

example11.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

76 lines (64 loc) · 2.37 KB

master

/

example11.java

Copy path

Top

File metadata and controls

• Code
• Blame

76 lines (64 loc) · 2.37 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

import rx.Observable;

import rx.Subscriber;

import java.util.ArrayList;

import java.util.List;

/**

*

* Exact example as 10 but uses the doOnNext() operator

* to add extra behavior each time an item is emitted

*

* Created by matie on 26/04/15.

*/

public class example11{

public static void main(String[] args){

//doOnNext(item) - do something else with the next emitted item before the final OnNext() call

//by the Subscriber

query("rx-OnNext").flatMap(urls -> Observable.from(urls))

.flatMap(url -> getTitle(url))

.filter(title -> title != null)

.take(3)

.doOnNext(title -> addPrefix(title))

.subscribe(title -> System.out.println(title));

}

private static void addPrefix(String title) {

System.out.println("doOnNext " + title);

}

//We could have used just() here, but I want the subscriber to ONLY print out my modified text.

private static Observable<String> getTitle(String Url){

return Observable.create(subscriber -> mapUrlToTitle(subscriber, Url));

}

private static void mapUrlToTitle(Subscriber<? super String> subscriber, String url) {

if(!subscriber.isUnsubscribed()){

//return null if 404

if(!url.equals("404")){

subscriber.onNext("Example title for " + url);

}else{

subscriber.onNext(null);

}

subscriber.onCompleted();

}

}

/**

* Re-using the query method in this example

* I prefer the lambda expressions as they are easier to extend. ANOTHER PLUS.

*/

private static Observable<List<String>> query(String text) {

return Observable.create(subscriber -> createAndEmitList(subscriber, text));

}

//I only have to deal with this part of the code and keep our query method untouched.

// If i == 2, I will print 404.

private static void createAndEmitList(Subscriber<? super List<String>> subscriber, String text){

List<String> myList = new ArrayList<String>();

for(int i = 0 ; i < 6 ; i++){

if(i == 2){

myList.add(404+"");

continue;

}

myList.add(text+ i + ".com");

}

if(!subscriber.isUnsubscribed()){

subscriber.onNext(myList);

subscriber.onCompleted();

}

}

}