Я новичок в rxjava
.У меня есть простое определение подписчика, как показано ниже для обработки файлов.Это работает нормально.
observable.subscribe(
data -> System.out.println(data)
Throwable::printStackTrace,
() -> log.info("File Processing Completed")
);
Но когда я пытаюсь использовать Schedulers
, как показано ниже, это не работает.Я не получаю никаких исключений или ошибок.
observable.subscribeOn(Schedulers.newThread())
.subscribe(
data -> System.out.println(data)
Throwable::printStackTrace,
() -> log.info("File Processing Completed")
);
что-то не так в моей конфигурации?