Main.java

package rxtest;

import io.reactivex.Observable;

public class Main {

	private void test1() {
		Observable.range(1,  10).filter(i -> i % 2 == 0).subscribe(System.out::println, Throwable::printStackTrace);
	}
	
	public void run(String[] args) {
		test1();
	}

	public static void main(String[] args) {
		(new Main()).run(args);
	}

}