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("123")
        .map(s -> Integer.parseInt(s)+1)
        .subscribe(i -> System.out.println("subscriber = "+i));
  }

}


@@ -27,21 +27,94 @@
 ort 
-rx.Observable
+java.util.ArrayList;%0Aimport java.util.List;%0Aimport rx.Observable;%0Aimport rx.Subscriber
 ;%0Aim
@@ -245,144 +245,614 @@
  %7B%0A%0A
-%0A%0A  public static void main(String%5B%5D args) %7B%0A    Observable.just(%22123%22)%0A        .map(s -%3E Integer.parseInt(s)+1)%0A        .subscribe(i -%3E
+  // Returns a List of website URLs based on a text search%0A  static Observable%3CList%3CString%3E%3E query(String text) %7B%0A    return Observable.create(new Observable.OnSubscribe%3CList%3CString%3E%3E() %7B%0A      @Override%0A      public void call(Subscriber%3C? super List%3CString%3E%3E subscriber) %7B%0A        subscriber.onNext(new ArrayList%3CString%3E()%7B%7B%0A          add(%22one%22);%0A          add(%22two%22);%0A          add(%22three%22);%0A        %7D%7D);%0A        subscriber.onCompleted();%0A      %7D%0A    %7D);%0A  %7D%0A%0A  public static void main(String%5B%5D args) %7B%0A    query(%22Hello, world!%22)%0A        .subscribe(urls -%3E %7B%0A          for (String url : urls)%0A           
  Sys
@@ -871,26 +871,23 @@
 tln(
-%22subscriber = %22+i)
+url);%0A        %7D
 );%0A 

Outputting a list of inputs