package lt.markmerkk;

import rx.Observable;
import rx.functions.Action1;
import rx.functions.Func1;

/**
 * Created by mariusmerkevicius on 1/27/16.
 */
public class Main {



  public static void main(String[] args) {
    Observable.just("observable")
        .map(s -> s+s)
        .subscribe(s -> System.out.println("subscriber = "+s));
  }

}


@@ -238,42 +238,183 @@
 st(%22
-observable%22)%0A        .map(s -%3E s+s
+123%22)%0A        .map(new Func1%3CString, Integer%3E() %7B%0A          @Override%0A          public Integer call(String s) %7B%0A            return Integer.parseInt(s)+1;%0A          %7D%0A        %7D
 )%0A  
@@ -430,17 +430,17 @@
 bscribe(
-s
+i
  -%3E Syst
@@ -470,17 +470,17 @@
 ber = %22+
-s
+i
 ));%0A  %7D%0A

Outputting different objects.