Вопросы с тегом «rxjs»

Какая разница между Promiseи Observableв Angular? Пример каждого из них поможет понять оба случая. В каком сценарии мы можем использовать каждый

Когда я должен хранить Subscriptionэкземпляры и вызывать их unsubscribe()в течение жизненного цикла NgOnDestroy, а когда я могу просто игнорировать их? Сохранение всех подписок вносит много ошибок в код компонента. HTTP Client Guide игнорирует такие подписки: getHeroes() {...

Я изучаю паттерны Angular RxJ и не понимаю разницы между a BehaviorSubjectи an Observable. Насколько я понимаю, BehaviorSubjectзначение a может со временем меняться (на него можно подписаться и подписчики могут получать обновленные результаты). Кажется, это точно такая же цель Observable. Когда вы...

У меня проблема с HTTP в Angular. Я просто хочу , чтобы GETв JSONсписок и показать его в представлении. Сервисный класс import {Injectable} from "angular2/core"; import {Hall} from "./hall"; import {Http} from "angular2/http"; @Injectable() export class HallService { public http:Http; public static...

Используя Http, мы вызываем метод, который выполняет сетевой вызов и возвращает наблюдаемый http: getCustomer() { return this.http.get('/someUrl').map(res => res.json()); } Если мы возьмем это наблюдаемое и добавим к нему несколько подписчиков: let network$ = getCustomer(); let subscriber1 =...

Я не понимаю разницу между а Subjectи а BehaviorSubject. Это просто BehaviorSubjectимеет

Я пытаюсь обернуть голову вокруг наблюдаемых. Мне нравится, как наблюдаемые решения решают проблемы развития и читабельности. Как я читаю, преимущества огромны. Наблюдаемые данные по HTTP и коллекциям кажутся простыми. Как я могу преобразовать что-то вроде этого в наблюдаемую картину. Это из моего...

Вам нужно отписаться от Angular 2 http-вызовов, чтобы предотвратить утечку памяти? fetchFilm(index) { var sub = this._http.get(`http://example.com`) .map(result => result.json()) .map(json => { dispatch(this.receiveFilm(json)); }) .subscribe(e=>sub.unsubscribe()); ......

У меня есть сервис Angular 2: import {Storage} from './storage'; import {Injectable} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; @Injectable() export class SessionStorage extends Storage { private _isLoggedInSource = new Subject<boolean>(); isLoggedIn =...

Я только что перешел с Angular 2 beta16 на beta17 , который, в свою очередь, требует rxjs 5.0.0-beta.6. (Журнал изменений здесь: https://github.com/angular/angular/blob/master/CHANGELOG.md#200-beta17-2016-04-28 ) В бета16 все работало хорошо в отношении функциональности Observable / map. Следующие...

У меня возникла проблема с Observable.ofфункцией импорта в моем проекте. Мой Интеллий все видит. В моем коде у меня есть: import {Observable} from 'rxjs/Observable'; и в моем коде я использую это так: return Observable.of(res); Любые...

Мне нужно создать подписку на Observableтот, который сразу же удаляется при первом вызове. Есть ли что-то вроде: observable.subscribeOnce(func); В моем случае я создаю подписку в обработчике экспресс-маршрута, и подписка вызывается несколько раз для каждого...

Теперь у меня есть начальная страница, где у меня есть три ссылки. Как только вы нажмете на последнюю ссылку «друзья», появится соответствующий компонент друзей. Там я хочу получить / просмотреть список моих друзей в файле friends.json. До сих пор все работает отлично. Но я все еще новичок в...

Функция more()должна возвращать Observableзапрос get export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ // return empty observable } } private fetch = (): Observable<Response> => { return...

Машинописный код: import { Injectable } from '@angular/core'; import { Observable } from 'rxjs/Observable'; import { of } from 'rxjs/observable/of'; import { Hero } from './hero'; import { HEROES } from './mock-heroes'; @Injectable({ providedIn: 'root' }) export class HeroService { constructor() {...

Это единственное различие между Observable.ofи Observable.fromформат аргументов? Вроде и Function.prototype.callа Function.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() => {})...

Я получил ошибку node_modules / rxjs / internal / types.d.ts (81,44): ошибка TS1005: ';' ожидается. после установки Angular 6. Проверьте ошибку: ERROR in node_modules/rxjs/internal/types.d.ts(81,44): error TS1005: ';' expected. node_modules/rxjs/internal/types.d.ts(81,74): error TS1005: ';'...

Я хотел бы закрыть раскрывающееся меню входа в систему, когда пользователь щелкает где-нибудь за пределами этого раскрывающегося списка, и я хотел бы сделать это с помощью Angular2 и с "подходом" Angular2 ... Я реализовал решение, но я действительно не уверен в нем. Я думаю, что должен быть самый...

Я думаю, что я неправильно понимаю что-то фундаментальное, потому что, на мой взгляд, это должен быть самый простой случай для наблюдаемого, но на всю жизнь я не могу понять, как это сделать из документации. По сути, я хочу уметь это делать: // create a dummy observable, which I would update...

Я нашел несколько реализаций, AuthGuardкоторые используют take(1). В своем проекте я использовал first(). Оба работают одинаково? import 'rxjs/add/operator/map'; import 'rxjs/add/operator/first'; import { Observable } from 'rxjs/Observable'; import { Injectable } from '@angular/core'; import {...