Observable.create((ObservableOnSubscribe<String>) emitter -> { String result = doLongRunningTask(); emitter.onNext(result); emitter.onComplete(); }) .subscribe(result -> { updateUI(result); });