typescript - Firebase en RxJS

Ik heb een functie gemaakt die naar waardegebeurtenissen luistert:

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

Wanneer

Lees verder →

angular - RXJS-operatoren werken niet met firebase

Ik gebruik de RXJS-operatoren met de Firebase-observable (distinct en filter). Dit is mijn Firebase-boom hier. Dit is mijn code:

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

Lees verder →

javascript - Typescript-module lost 'rxjs' op een andere manier in hetzelfde bestand

Ik heb uren besteed aan rondjes draaien, dus tijd voor nog een obscure vraag.

Ik ben binnen een lerna mono-repo, met twee subprojecten, ProjectA en ProjectB.

ProjectA heeft een afhankelijkheid van rxjs, net als

Lees verder →

TypeScript - RxJS6: stream resetten na voltooiing

Ik heb een beetje geëxperimenteerd met RxJS 6. Ik probeer dragstart, dragmove en dragend te implementeren. Dit is de code die ik tot nu toe heb.

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

Lees verder →

typescript - Met RxJs in Angular, moet ik alleen de Observables die in de component zijn gemaakt, voltooien?

Eigenlijk ben ik nog steeds niet echt zeker over het opruimen van reactieve code in Angular-componenten. Zijn de volgende regels correct en voldoende?

Mijn regels voor een reactieve component:

• in de handleiding x.subscribe():

  • als u x.takeUntil(...) of een gelijksoortig construct gebruikt, is geen handmatige opruiming nodig
  • als x.complete() wordt aangeroepen in de componentruimte, dan geen handmatige opruiming
  • ander
    Lees verder →

typescript - rxjs-paginering met abonnement op elke pagina

We voeren een query uit op graphql via websocket om een abonnement te hebben op een lijst van entiteiten. We gebruiken paginering omdat de lijst naar verwachting oneindig scrollbaar is. We willen ook wijzigingen in de database in realtime zien in de lijst aan de front-end.

Deze lijst kan worden gefilterd, gesorteerd en gepaginateerd.

We hebben de klasse SelectParams die ons daarbij helpt:

export class S

Lees verder →

typescript - Angular 6 Fout bij gebruik van RxJS: Kan eigenschap 'call' van undefined niet lezen

Ik probeer een Angular 5-app te migreren naar Angular 6 en ik heb deze ene blok RxJS-code die me puzzelt. Ik heb genoeg gegoogeld en de RxJS-documentatie doorgenomen om te weten dat ik .pipe zou moeten gebruiken, maar ik kan de syntaxis niet helemaal krijgen.

De code retournee

Lees verder →

javascript - RXJS Angular - Hoe een functie aanroepen aan het einde van een foreach-lus die observables bevat?

this.attachmentList.forEach((attachment, i) => { this.service.getPageOfAttachment().flatMap(response => this.service.download((JSON.parse(response['Content']).mediaUrl))) .subscribe(response => { }, error =&g

Lees verder →

javascript - Hoe selectief hot (gedeelde) observables te emitten in RxJS?

In mijn code heb ik een hot observable (cold observable via de share()-operator geleid) die waarden uitzendt met identificatoren (d.w.z. het payload-type bevat een "id" stringeigenschap). Een aantal observers filtert vervolgens de uitgezonden waarden op basis van genoemde id.

Ik denk nu dat mijn code een enorme prestatievermindering ondervindt, aangezien elke observer elke waarde die wordt uitgezonden moet filteren. Of beter gezegd, er wordt elke keer dat ik een nieuwe observer op de ge

Lees verder →

typescript - Angular 6 - rxjs-eigenschap 'map' bestaat niet op type 'observable'

Ik krijg deze foutmelding wanneer ik upgrade naar Angular 6. Ik zie de documentatie om .pipe() te gebruiken, maar ik begrijp niet hoe ik pipe moet gebruiken wanneer er meerdere .map() zijn zoals hieronder. Heb je hulp nodig...

import {Injectable} from '@angular/core'; i

Lees verder →