rxjs5

6зной

2ответ

Почему Rxjs publishReplay (1) .refCount() не воспроизводится?

Почему publishReplay (1) .refCount() не воспроизводит последнее значение для поздних подписчиков? a = new Rx.Subject(); b = a.publishReplay(1).refCount(); a.subscribe(function(x){console.log(

0зной

2ответ

Разница между подпиской RxJS5 и наблюдателем

Я вижу некоторые вопросы/ответы, связанные с Rx Subscriptions/Observers, но они могут быть для более старых версий Rx, а также не для RxJS, которые могут соответствовать другому API. У меня создалось

1зной

1ответ

Как испускать значения из массива в противоположном направлении, начиная с последнего элемента?

Вот где I'am: const observer = (item) => { console.log(item); } Observable.from([1,2,3,4,5]) .take(3) .******* .subscribe(observer); То, что я хотел бы получить в консоли: 5

0зной

2ответ

Rxjs - Невозможно преобразовать холодный наблюдаемый в горячий

Итак, я использую Angular 2 и изо всех сил пытаюсь сделать наблюдаемый HTTP-запрос доступным для нескольких наблюдателей. В частности, я хотел бы поделиться всеми типами ответов, включая ошибки. Я про

0зной

1ответ

finally() не вызывается при возврате empty() в catch()

Я написал общий метод запроса, который должен показывать индикатор загрузки во время выполнения запроса. Если возникает ошибка (например, 404), я показываю сообщение в .catch, а затем return Observabl

6зной

1ответ

Оператор с общим наблюдаемым и startWith

У меня вопрос о многоадресных наблюдаемых и неожиданном (для меня) поведении, которое я заметил. const a = Observable.fromEvent(someDom, 'click') .map(e => 1) .startWith(-1) .share();

1зной

1ответ

Понимание доли() Оператор RxJS в действии вместе с Rx.Observable.ajax

Я пытаюсь понять поведение оператора RxJS 5share(). Согласно учебникам и документации, share() превращает холодный наблюдаемый в горячий. Я стараюсь видеть это в действии. Вот то, что я пробовал: cons