Als «rxjs» getaggte Fragen

Was ist der Unterschied zwischen Promiseund Observablein Angular? Ein Beispiel zu jedem Fall wäre hilfreich, um beide Fälle zu verstehen. In welchem ​​Szenario können wir jeden Fall

Wann sollte ich die SubscriptionInstanzen speichern und unsubscribe()während des NgOnDestroy-Lebenszyklus aufrufen und wann kann ich sie einfach ignorieren? Das Speichern aller Abonnements führt zu viel Chaos im Komponentencode. HTTP-Client-Handbuch ignoriert Abonnements wie folgt: getHeroes()...

Ich untersuche Angular RxJs Muster und verstehe den Unterschied zwischen a BehaviorSubjectund an nicht Observable. Nach meinem Verständnis ist a BehaviorSubjectein Wert, der sich im Laufe der Zeit ändern kann (kann abonniert werden und Abonnenten können aktualisierte Ergebnisse erhalten). Dies...

Ich habe ein Problem mit HTTP in Angular. Ich möchte nur GETeine JSONListe erstellen und in der Ansicht anzeigen. Serviceklasse import {Injectable} from "angular2/core"; import {Hall} from "./hall"; import {Http} from "angular2/http"; @Injectable() export class HallService { public http:Http;...

Mit Http rufen wir eine Methode auf, die einen Netzwerkaufruf ausführt und eine beobachtbare http zurückgibt: getCustomer() { return this.http.get('/someUrl').map(res => res.json()); } Wenn wir dies beobachten und mehrere Abonnenten hinzufügen: let network$ = getCustomer(); let...

Der Unterschied zwischen a Subjectund a ist mir nicht klar BehaviorSubject. Ist es nur so, dass a BehaviorSubjectdie getValue()Funktion

Ich versuche, meinen Kopf um Observable zu wickeln. Ich mag die Art und Weise, wie Observables Entwicklungs- und Lesbarkeitsprobleme lösen. Während ich lese, sind die Vorteile immens. Observables auf HTTP und Sammlungen scheinen einfach zu sein. Wie kann ich so etwas in ein beobachtbares Muster...

Müssen Sie sich von Angular 2 http-Aufrufen abmelden, um Speicherverluste zu vermeiden? fetchFilm(index) { var sub = this._http.get(`http://example.com`) .map(result => result.json()) .map(json => { dispatch(this.receiveFilm(json)); }) .subscribe(e=>sub.unsubscribe()); ......

Ich habe einen Angular 2-Dienst: 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 =...

Ich habe gerade ein Upgrade von Angular 2 Beta16 auf Beta17 durchgeführt , was wiederum RXJS 5.0.0-Beta.6 erfordert. (Änderungsprotokoll hier: https://github.com/angular/angular/blob/master/CHANGELOG.md#200-beta17-2016-04-28 ) In der Beta16 funktionierte alles in Bezug auf die Observable /...

Ich habe Probleme mit der Importfunktion Observable.ofin meinem Projekt. Mein Intellij sieht alles. In meinem Code habe ich: import {Observable} from 'rxjs/Observable'; und in meinem Code benutze ich es so: return Observable.of(res); Irgendwelche

Ich muss ein Abonnement für ein Abonnement erstellen Observable, das sofort entsorgt wird, wenn es zum ersten Mal aufgerufen wird. Gibt es so etwas wie: observable.subscribeOnce(func); In meinem Anwendungsfall erstelle ich ein Abonnement in einem Express-Routen-Handler und das Abonnement wird...

Jetzt habe ich eine erste Seite, auf der ich drei Links habe. Sobald Sie auf den letzten Link "Freunde" klicken, wird die entsprechende Freundeskomponente initiiert. Dort möchte ich eine Liste meiner Freunde abrufen / abrufen, die in der Datei friends.json gespeichert ist. Bis jetzt funktioniert...

Die Funktion more()soll eine Observablevon einer get-Anfrage zurückgeben export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ // return empty observable } } private fetch = (): Observable<Response> =>...

Typoskript-Code: 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() {...

Ist der einzige Unterschied zwischen Observable.ofund Observable.fromdem Argumentformat? Wie das Function.prototype.callund Function.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() => {})

Ich möchte mein Dropdown-Menü für das Anmeldemenü schließen, wenn der Benutzer auf eine beliebige Stelle außerhalb dieses Dropdowns klickt, und ich möchte dies mit Angular2 und dem Angular2-Ansatz tun ... Ich habe eine Lösung implementiert, bin aber nicht sicher. Ich denke, es muss einen...

Ich habe einen Fehler von node_modules / rxjs / internal / types.d.ts (81,44): Fehler TS1005: ';' erwartet. nach der Installation von Angular 6. Überprüfen Sie den Fehler: ERROR in node_modules/rxjs/internal/types.d.ts(81,44): error TS1005: ';'

Ich denke, ich muss etwas Grundlegendes falsch verstehen, denn in meinen Augen sollte dies der grundlegendste Fall für ein Beobachtbares sein, aber für mein Leben kann ich aus den Dokumenten nicht herausfinden, wie es geht. Grundsätzlich möchte ich dazu in der Lage sein: // create a dummy...

Ich habe einige Implementierungen von AuthGuards gefunden, die diese verwenden take(1). In meinem Projekt habe ich verwendet first(). Arbeiten beide gleich? import 'rxjs/add/operator/map'; import 'rxjs/add/operator/first'; import { Observable } from 'rxjs/Observable'; import { Injectable } from...