File tree Expand file tree Collapse file tree
src/main/java/com/fernandocejas/java/samples/observable Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11package com .fernandocejas .java .samples .observable ;
22
33import com .fernandocejas .java .samples .Const ;
4+ import java .util .Arrays ;
45import rx .Observable ;
56
67public 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}
You can’t perform that action at this time.
0 commit comments