Observable Example

MainActivity.java

//---

Observable
	.just(1, 2, 3, 4, 5)
	.filter(new Func1<Integer, Boolean>() {
		@Override
		public Boolean call(Integer integer) {
			return integer % 2 != 0;
		}
	}).subscribe(new Observer<Integer>() {
		@Override
		public void onSubscribe(Disposable d) {
		}
		
		@Override
		public void onNext(Integer integer) {
			Log.i(TAG, String.valueOf(integer));
		}
		
		@Override
		public void onError(Throwable e) {
			Log.e(TAG, "Error");
		}

		@Override
		public void onComplete() {
			Log.i(TAG, "No more results");
		}
	});
   
//This will log 1 - 3 - 5