@lacredin
Программист

Как в RxJava асинхронно выполнять намерения?

Я впервые использую rxjava и прочитав о
subscribeOn(Schedulers.newThread())
observeOn(Schedulers.newThread())
Я понадеялся, что смогу сделать вот такую штуку:
Subject<DataObservable> commandToService.subscribeOn(Schedulers.newThread()).observeOn(Schedulers.newThread()).subscribe(observer);
//слушатель
private Observer<DataObservable> observer = new Observer<DataObservable>() {
        @Override
        public void onNext(DataObservable o) {
              //какая-то долгая операция
        }
    };

private void postCommand(DataObservable command){
        commandToService.onNext(command);
}

Я хотел, чтобы из разных частей программы, вызывался postCommand, а observer выполнял различные долгие операции. Но оказалось, что намерения, создаваемые postCommand выполняются синхронно, то есть пока не завершится одно намерение, новое не стартует, вопреки моему ожиданию.
Подскажите, можно ли заставить rxjava запускать намерения параллельно или мне придётся в observer.onNext создавать новые потоки самостоятельно?
  • Вопрос задан
  • 210 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы
SoftAge Новосибирск
До 200 000 ₽
SoftAge Новосибирск
До 150 000 ₽
Drum Pads 24 Ульяновск
от 90 000 до 160 000 ₽
04 июн. 2020, в 00:28
20000 руб./за проект
03 июн. 2020, в 23:41
75000 руб./за проект
03 июн. 2020, в 22:09
20000 руб./за проект