observable- все статьи тега


Отказ от подписки на RxJS observable с использованием takeUntil и combineLatest не работает

Я использую принятый шаблон для отмены подписки: private ngUnsubscribe: Subject<void> = new Subject(); ngOnDestroy() { this.ngUnsubscribe.next(); this.ngUnsubscribe.complete(); } Однако у меня возникли проблемы со следующим кодом rxjs, использующим takeUntil и combineLatest: this.observableA$.pipe( takeUntil(this.ngUnsubscribe), combineLatest( this.observableB$, this.observableC$ ) ).subscribe(([A, B, C]) => { // do some work }) Эта по ...

Angular2 Observable-как дождаться завершения всех вызовов функций в цикле, прежде чем продолжить?

Я пытаюсь улучшить свои знания Angular2, перенеся приложение, написанное в настоящее время на Angular1 Одна особенность, в частности, ставит меня в тупик. Я пытаюсь воспроизвести функцию, в которой вызывающая функция ожидает продолжения, пока вызываемая функция не завершит цикл обещаний. В угловых одну функцию я вызываю в основном выглядит так: this.processStuff = function( inputarray, parentnodeid ) { var promises = []; var _self = this; angular.forEach( inputarray , function( no ...

Оператор RxJS combineAll, пояснение

Я пытаюсь понять, как combineAll работы оператора. Я использую следующий пример из официальной документации: const source = Rx.Observable.interval(1000).take(2); const example = source.map(val => Rx.Observable.interval(1000).map(i => `Result (${val}): ${i}`).take(5)); const combined = example.combineAll(); Выход тогда : ["Result (0): 0", "Result (1): 0"] ["Result (0): 1", "Result (1): 0"] ["Result (0): 1", "Result (1): 1"] ["Result (0): 2", "Result (1): 1"] ["Result (0): 2", "Result ...

Angular2-несколько зависимых последовательных вызовов http api

Я создаю приложение Angular2, и один из компонентов должен сделать несколько вызовов API, которые зависят от предыдущих. В настоящее время у меня есть служба, которая делает вызов API, чтобы получить список телепередач. Для каждого шоу мне нужно вызвать другой API несколько раз, чтобы пройти через структуру, чтобы определить, существует ли шоу на сервере Plex. Документация API находится здесь Для каждого шоу мне нужно сделать следующие звонки: и получить правильные данные, чтобы определить, ...

Angular/RxJs когда я должен отписаться от " подписки`

когда я должен хранить Subscription экземпляры и вызывать unsubscribe() во время жизненного цикла NgOnDestroy и когда я могу просто игнорировать их? сохранение всех подписок вносит много беспорядка в код компонента. руководство клиента HTTP игнорировать подписки, как это: getHeroes() { this.heroService.getHeroes() .subscribe( heroes => this.heroes = heroes, error => this.errorMessage = <any>error); } в то же время ...

Делегирование: EventEmitter или наблюдаемый в угловом

Я пытаюсь реализовать что-то вроде шаблона делегирования в угловой. Когда пользователь нажимает на nav-item, Я хотел бы вызвать функцию, которая затем выдает событие, которое, в свою очередь, должно обрабатываться каким-либо другим компонентом, прослушивающим событие. вот сценарий: у меня есть Navigation компоненты: import {Component, Output, EventEmitter} from 'angular2/core'; @Component({ // other properties left out for brevity events : ['navchange'], template:` <d ...

Когда мы должны использовать Observer и Observable

интервьюер спросил меня: что это Observer и Observable и когда мы должны использовать их? Я не знал об этих терминах, поэтому, когда я вернулся домой, и я начал гуглить о Observer и Observable и нашел несколько точек из разных ресурсов: 1) Observable класс а Observer - это интерфейс. 2) Observable класс поддерживает список Наблюдатели. 3) когда наблюдаемый объект обновляется, он вызывает update() метод каждого из своих наблюдателей, чтобы уведомить, что он изменился. я нашел эт ...

Разница между потоками Java 8 и наблюдаемыми RxJava

являются ли потоки Java 8 похожими на наблюдаемые RxJava? Java 8 определение потока: классы в новом java.util.stream пакет предоставляет API потока для поддержка операций функционального стиля над потоками элементов. ...

RxJava Выборка Наблюдаемых Параллельно

Мне нужна помощь в реализации параллельных асинхронных вызовов в RxJava. Я выбрал простой случай использования, в котором первый вызов извлекает (а не ищет) список продуктов (плитка), которые будут отображаться. Последующие вызовы выходят и получают (а) обзоры и (б) изображения продукта после нескольких попыток я добрался до этого места. 1 Observable<Tile> searchTile = searchServiceClient.getSearchResults(searchTerm); 2 List<Tile> allTiles = new ArrayList<Tile>(); 3 ...