RxJS - оператор блокировки
В RxJava есть оператор Observable.toBlocking() для синхронного извлечения данных наблюдаемой. Я не могу найти похожий оператор для RxJS. Я хочу использовать этот оператор для улучшения моего кода с помощью Rx и без использования другой библиотеки функционального программирования...
1 ответ
См планировщики
Если вы не предоставите планировщик, RxJS выберет планировщик по умолчанию, используя принцип наименьшего параллелизма. Это означает, что выбран планировщик, который вводит наименьшее количество параллелизма, которое удовлетворяет потребностям оператора.
Пока вы не укажете планировщик, RxJS сам выбирает планировщик блокировки / синхронно разрешает наблюдаемое ( непосредственный планировщик), как вы можете видеть в этом jsbin - первая наблюдаемая завершается до того, как запускается вторая.
Если вы хотите явно контролировать уровень параллелизма, вы можете сделать это, передав определенный планировщик оператору, который поддерживает эту опцию.