RXjava2 subscribeOn (Schedulers. ()) Не работает - PullRequest
0 голосов
/ 20 ноября 2018

Я новичок в 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")
                  );

что-то не так в моей конфигурации?

...