angular - Ergebnis eines Observables mit combineLatest und Rxjs zurückgeben

Ich möchte das Ergebnis eines Observables erhalten, das jedes Mal, wenn sich der Wert ändert, den Standardwert subtrahiert.

Jedes Mal, wenn sich der Wert ändert, wird der Standardwert um den in das Eingabefeld eingegebenen neuen Wert reduziert.

Zum Beispiel ist der Standardwert 5.

Weiterlesen →

angular - Wie greife ich über rxjs mit SystemJS/Angular2 auf Rx.Scheduler.immediate zu?

Ich möchte den ImmediateScheduler von RxJS in meinem Angular2-Projekt verwenden.

In meiner RxJS-Installation existiert dies jedoch nicht. Ich benutze in meiner package.json „rxjs“: „5.0.0-beta.12“, was von Angular 2.1.2 benötigt wird.
Wenn ich im Ordner node_modules/ nachschaue, finde ich einen Ordner ‚rxjs‘ und einen Ordner ‚rx‘. Der ImmediateScheduler ist nicht Teil von ‚rxjs‘, sondern von ‚rx‘. Ich finde ihn dort in ‚rx/dist/rx.lite.js‘ oder sogar in ‚rx/ts/rx/rx-lite.ts‘ als Typ

Weiterlesen →

typescript - Rxjs: Kurzschreibweise zum Erstellen eines Observables aus einem Wert oder Observable

Ich verwende rxjs mit TypeScript. Ich habe die folgenden zwei einfachen Funktionen geschrieben. Aber ich vermute, dass rxjs so eine Funktionalität bereits hat. Hat rxjs?

export function isObservable(value: any): value is Observable<any&g

Weiterlesen →

TypeScript - Firebase und RxJS

Ich habe eine Funktion erstellt, die auf Wert-Ereignisse hört:

getUnreadMessages() : Observable<any>{ return new Observable(observer =>{ firebase.database().ref('messages/' + this.userService.getUserID()).on("value", (snapshot : any) =>{ let count = 0; ...some more logic here... observer.next(count); observer.complete(); }, (error) =>{ observer.error(error); }) }) }

Wenn sich di

Weiterlesen →

angular - RXJS-Operatoren funktionieren nicht mit Firebase

Ich benutze die RXJS-Operatoren mit dem Firebase-Observable (distinct und filter). Dies ist mein Firebase-Baum hier. Dies ist mein Code:

let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.l

Weiterlesen →

javascript - Typescript Modul löst 'rxjs' im selben Datei unterschiedlich auf

Ich habe Stunden damit verbracht, im Kreis zu gehen, also ist es Zeit für eine weitere obskure Frage.

Ich befinde mich in einem lerna Mono-Repository, mit zwei Unterprojekten, ProjectA und ProjectB.

ProjectA hat eine Abhängigke

Weiterlesen →

TypeScript - RxJS6: Stream nach Abschluss zurücksetzen

Ich habe ein wenig mit RxJS 6 herumgespielt. Ich versuche, dragstart, dragmove und dragend zu implementieren. Dies ist der Code, den ich bisher habe.

import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; i

Weiterlesen →

typescript - Mit RxJs in Angular muss ich nur die Observables abschließen, die in der Komponente erstellt wurden?

Grundsätzlich bin ich mir immer noch nicht wirklich sicher über die Bereinigung von reaktivem Code in Angular-Komponenten. Sind die folgenden Regeln korrekt und ausreichend?

Meine Regeln für eine reaktive Komponente:

• bei manueller x.subscribe():

  • wenn x.takeUntil(...) oder ein ähnliches Konstrukt verwendet wird, dann keine manuelle Bereinigung
  • wenn x.complete() im Komponentenbereich aufgerufen wird, dann keine manuelle Bere
    Weiterlesen →

TypeScript - RxJS-Paginierung mit Abonnement für jede Seite

Wir fragen graphql über Websocket ab, um ein Abonnement für eine Liste von Entitäten zu haben. Wir verwenden Paginierung, da die Liste unendlich scrollbar sein soll. Wir möchten auch Änderungen in der Datenbank in Echtzeit in der Liste auf der Benutzeroberfläche sehen.

Diese Liste kann gefiltert, sortiert und paginiert werden.

Wir haben die Klasse SelectParams, die uns dabei hilft:

export class SelectPa

Weiterlesen →

typescript - Angular 6 Fehler bei der Verwendung von RxJS: Kann Eigenschaft 'call' von undefined nicht lesen

Ich versuche, eine Angular-5-App auf Angular 6 zu migrieren, und ich habe diesen einen Block RxJS-Code, der mich ratlos macht. Ich habe gegoogelt und die RxJS-Dokumentation genug durchgelesen, um zu wissen, dass ich .pipe verwenden sollte, aber ich bekomme die Syntax nicht richtig h

Weiterlesen →