Skip to content

Commit c099de4

Browse files
committed
Add samples for map operator.
1 parent 4783789 commit c099de4

1 file changed

Lines changed: 15 additions & 0 deletions

File tree

src/main/java/com/fernandocejas/java/samples/observable/Scenario01.java

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.fernandocejas.java.samples.observable;
22

33
import com.fernandocejas.java.samples.Const;
4+
import java.util.Arrays;
45
import rx.Observable;
56

67
public class Scenario01 {
@@ -18,6 +19,9 @@ public Scenario01() {
1819
builder.append("FlatMap elements: ")
1920
.append(Const.LINE_FEED)
2021
.append(flatMapElements());
22+
builder.append("Map elements: ")
23+
.append(Const.LINE_FEED)
24+
.append(mapElement());
2125
return builder.toString();
2226
}
2327

@@ -32,4 +36,15 @@ private String flatMapElements() {
3236
.subscribe(string -> { output.append(string).append(Const.LINE_FEED); });
3337
return output.toString();
3438
}
39+
40+
private String mapElement() {
41+
final StringBuilder output = new StringBuilder();
42+
Observable.from(Arrays.asList(1, 3, 5))
43+
.map(number -> output
44+
.append("Map element: ")
45+
.append(String.valueOf(number + number))
46+
.append(Const.LINE_FEED))
47+
.subscribe();
48+
return output.toString();
49+
}
3550
}

0 commit comments

Comments
 (0)