SimpleObservable.java

package com.reactive.chapter3;

import rx.Observable;

public class SimpleObservable {
	
	public SimpleObservable go() {
		Observable<Integer> arrayObservable = Observable.from(new Integer[] {3, 5, 8});
		  arrayObservable.subscribe(System.out::println);
		  return this;
	}
	
	public SimpleObservable go2() {
		Observable.just('j', 'a', 'v', 'a').subscribe(System.out::println);
		return this;
	}

	public static void main(String[] args) {
		new SimpleObservable().go().go2();
	}
}