angular - Palauta observablen tulos combineLatestin ja Rxjs:n avulla

Haluan saada havaittavan tuloksen, joka vähentää oletusarvon joka kerta, kun arvo muuttuu

Joka kerta, kun arvo muuttuu, se vähentää oletusarvosta syötetyn uuden arvon syöttökenttään.

Esimerkiksi oletusarvo on 5.

Syötän 4 syöttökenttään

Tulos on 5-4=1, joten haluan näyttää

Lue lisää →

angular - Kuinka käyttää Rx.Scheduler.immediatea rxjs:n kautta SystemJS/Angular2:ssa?

Haluaisin käyttää RxJS:n ImmediateScheduleria Angular2-projektissani.

Kuitenkin omassa RxJS-asennuksessani tätä ei ole olemassa. Käytän package.json-tiedostossani "rxjs": "5.0.0-beta.12", joka vaaditaan Angular 2.1.2:ssa.
Kun katson node_modules/-kansiossa, löydän kansion 'rxjs' ja kansion 'rx'. ImmediateScheduler ei ole osa 'rxjs':iä vaan 'rx':ää. Voin löytää sen sieltä 'rx/dist/rx.lite.js' tai jopa 'rx/ts/rx/rx-lite.ts' TypeScriptinä, jota käytän.

Yritän

Lue lisää →

typescript - Rxjs: lyhennys havaittavan luomiseksi arvosta tai havaittavasta

Käytän rxjs:ää TypeScriptin kanssa. Kirjoitin seuraavat kaksi yksinkertaista funktiota. Mutta arvelen, että rxjsllä on jo tällainen toiminnallisuus. Onko rxjsllä?

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

Lue lisää →

typescript - Firebase ja RxJS

Tein funktion, joka kuuntelee arvo-tapahtumia:

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

Kun tietokanta muuttuu, näen

Lue lisää →

angular - RXJS-operaattorit eivät toimi firebasen kanssa

Käytän RXJS-operaattoreita Firebase-observableen (distinct ja filter). Tässä on Firebase-puuseni. Tässä on koodini:

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

Lue lisää →

javascript - Typescript-moduuli ratkaisee 'rxjs':n eri tavalla samassa tiedostossa

Olen käyttänyt tunteja pyöriessäni ympyrää, joten nyt on aika toiselle hämärälle kysymykselle.

Olen sisällä lerna monorepossa, jossa on kaksi aliprojektia, ProjectA ja ProjectB.

ProjectA riippuu rxjs:stä, samoin ku

Lue lisää →

typescript - RxJS6: nollaa virta suorittamisen jälkeen

Olen kokeillut hieman RxJS 6:ta. Yritän toteuttaa dragstart, dragmove ja dragend. Tämä on koodi, joka minulla on toistaiseksi.

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

Lue lisää →

typescript - Tarvitsenko Angularissa RxJs:n kanssa päättää vain komponentissa luodut Observables?

Periaatteessa en ole vielä täysin varma Angular-komponenttien reaktiivisen koodin siivouksesta. Ovatko seuraavat säännöt oikein ja riittäviä?

Sääntöni reaktiiviselle komponentille:

  • on manuaalinen x.subscribe():

    • jos käytät x.takeUntil(...) tai vastaavaa rakennetta, niin ei manuaalista siivousta
    • jos x.complete() kutsutaan komponentin laajuudessa, silloin ei tarvita manuaalista siivousta
    • tai manuaalisesti .unsubsc

      Lue lisää →

typescript - rxjs sivutus tilausta jokaiseen sivuun

Kyselytämme graphql:ia websocketin kautta saadaksemme tilauksen entiteettien listalle. Käytämme sivutusta, koska listan oletetaan olevan loputtomasti vieritettävä. Haluamme myös nähdä tietokannassa tehdyt muutokset reaaliajassa listalla front-endissä.

Tätä luetteloa voidaan suodattaa, järjestää ja pilkkoa sivuihin.

Meillä on luokka SelectParams, joka auttaa meitä tekemään sen:

export class SelectParams

Lue lisää →

typescript - Angular 6 Virhe RxJS:ä käyttäessä: Ei voi lukea ominaisuutta 'call' määrittelemättömästä

Yritän siirtää Angular 5 -sovelluksen Angular 6:een, ja minulla on tämä yksi RxJS-koodilohko, joka on saanut minut hämmentymään. Olen Googlannut ja lukenut RxJS-dokumentaatiota tarpeeksi tietääkseni, että minun pitäisi käyttää .pipe, mutta en oikein saa syntaksia toimimaan.

Ko

Lue lisää →