Я пытаюсь создать пустой Observalbe
, чтобы запустить создание образа жесткого диска (долгая операция) в IO потоке:
Observable.empty()
.subscribeOn(Schedulers.io())
.subscribe(o -> {
try {
imageCreater.createImage(creatingImageObject, new File(imageCreateView.getImagePath()));
} catch (IOException e) {
imageCreateView.onError(e.getMessage());
}
});
Однако, ничего не происходит. Если исправить Observable.empty()
на Observable.just(1)
— все начинает работать!
Из-за чего так происходит?