ObservablesRun.java

public class ObservablesRun {

    public static void main(String[] args) {

	List<String> symbols = Arrays.asList("GOOG", "AAPL", "MSFT", "INTC");
	Observable<StockInfo> feed = StockServer.getFeeed(symbols);
	Disposable subscribe = feed.subscribeWith(new DisposableObserver<StockInfo>() {

	    int count = 0;

	    @Override
	    public void onNext(StockInfo t) {
		System.out.println(t);

		count++;
		if (count == 10) {
		    dispose();
		}
	    }

	    @Override
	    public void onError(Throwable e) {
		System.out.println("ERROR");

	    }

	    @Override
	    public void onComplete() {
		System.out.println("DONE");

	    }

	});

	System.out.println("Got observable");
    }
}