gistfile1.txt

		ObservableOnSubscribe<String> observableOnSubscribe = new ObservableOnSubscribe<String>() {

			@Override
			public void subscribe(ObservableEmitter<String> emitter) throws Exception {
				
				// This will be called when subscribe() is called
				
				// At this point 
				System.out.println(Thread.currentThread()+": ObservableOnSubscribe.subscribe() called");
				ImmutableList.of("one","two","three").forEach(it->{
					System.out.println(Thread.currentThread()+": emitter.onNext("+it+") called");
					emitter.onNext(it);
				});
			
				System.out.println(Thread.currentThread()+": emitter.onComplete() called");
				emitter.onComplete();
				System.out.println(Thread.currentThread()+": leaving subscribe()");
			}
		};
		
		System.out.println(Thread.currentThread()+": calling Observable.create()...");
		Observable obs = Observable.create(observableOnSubscribe);
		System.out.println(Thread.currentThread()+": Observable.create() complete");
		
		obs.observeOn(Schedulers.io()).subscribe(it->{
			System.out.println(Thread.currentThread()+": received "+it);
		});