Weboldal keresés

angular - Egy observable eredményének visszaadása a combineLatest és Rxjs segítségével

Szeretném megkapni egy megfigyelhető eredményét, amely minden alkalommal kivonja az alapértelmezett értéket, amikor az érték megváltozik

Minden alkalommal, amikor az érték megváltozik, kivonja az alapértelmezett értékből a beviteli mezőbe beírt új értéket

Például az alapértelmezett ér

További információ →

angular - Hogyan lehet hozzáférni az Rx.Scheduler.immediate-hoz az rxjs-en keresztül SystemJS/Angular2 használatával?

Szeretném használni az RxJS ImmediateScheduler-jét az Angular2 projektemben.

Azonban az én RxJS telepítésemben ez nem létezik. A package.json fájlomban a "rxjs": "5.0.0-beta.12" verziót használom, amelyre az Angular 2.1.2-nek van szüksége.
Amikor a node_modules/ mappában nézelődöm, találok egy 'rxjs' mappát és egy 'rx' mappát. Az ImmediateScheduler nem az 'rxjs'-hez tartozik, hanem az 'rx'-hez. Ott megtalálom a 'rx/dis

További információ →

typescript - Rxjs: rövidítés értékből vagy observable-ból való observable létrehozására

A rxjs-t használom TypeScript-tel. Írtam a következő két egyszerű függvényt. De azt hiszem, a rxjs-nek már van ilyen funkcionalitása. Van a rxjs-nek?

export function isObservable(value: any): value is Observable<any> { return value

További információ →

typescript - Firebase és RxJS

Készítettem egy függvényt, ami a value eseményekre figyel:

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); }) }) }

Amikor az adatbá

További információ →

angular - RXJS operátorok nem működnek a firebase-szel

Az RXJS operátorokat használom a Firebase observablessel (distinct és filter). Ez itt a Firebase fám. Ez a kódom:

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

További információ →

javascript - A Typescript modul azonos fájlban különbözően oldja fel az 'rxjs'-t

Órákat töltöttem azzal, hogy körbe-körbe jártam, szóval itt az ideje egy másik homályos kérdésnek.

Egy lerna monorepón belül vagyok, két alprojektel, ProjectA-val és ProjectB-vel.

ProjectA függ a rxjs-tól, akárcsak

További információ →

typescript - RxJS6: stream visszaállítása a befejezés után

Kicsit játszadoztam a RxJS 6-tal. Próbálom megvalósítani a dragstart, dragmove és dragend eseményeket. Ez a kódom eddig.

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

További információ →

typescript - Az Angularban RxJs használatával csak azokat az Observables-eket kell befejeznem, amelyeket a komponensben hoztam létre?

Alapvetően még mindig nem vagyok teljesen biztos az Angular komponensekben lévő reaktív kód takarításában. A következő szabályok helyesek és elegendőek?

A szabályaim egy reaktív komponenshez:

  • kézi x.subscribe():

    • ha x.takeUntil(...) vagy hasonló szerkezetet használ, akkor nincs szükség kézi takarításra
    • ha a x.complete() a komponens hatókörében van meghívva, akkor nincs szükség kézi takarításra
    • egyébként kézzel hívd

      További információ →

typescript - rxjs lapozás előfizetéssel minden oldalra

A graphql-t websocket-en keresztül kérdezzük le, hogy előfizessünk egy entitáslistára. Lapozást használunk, mivel a lista végtelenségig görgethetőnek van szánva. Azt is szeretnénk, hogy a frontenden a listában valós időben láthassuk az adatbázisban történt változásokat.

Ez a lista szűrhető, rendezhető és lapozható.

Van egy SelectParams osztályunk, amely segít nekünk ebben:

export class SelectParams {

További információ →

typescript - Angular 6 Hiba az RxJS használatakor: Nem lehet olvasni az 'call' tulajdonságot, mert undefined

Próbálok egy Angular 5 alkalmazást Angular 6-ra migrálni, és van egy blokk RxJS kód, ami megakasztott. Elég sokat gugliztam és átnéztem az RxJS dokumentációt ahhoz, hogy tudjam, hogy a .pipe-ot kellene használnom, de nem igazán értem a szintaxist.

A kód visszaadja az API-hívás

További információ →