javascript - RXJS Angular - Hvordan kalder man en funktion i slutningen af en foreach-løkke, der indeholder observables?

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

Læs mere →

javascript - Hvordan udløser man selektivt varme (delte) observables i RxJS?

I min kode har jeg et hot observable (koldt observable pipet gennem share()-operatoren), der udsender værdier med identifikatorer (dvs. payload-typen indeholder en "id" streng-egenskab). En række observatører på dette filtrerer derefter de udsendte værdier baseret på nævnte id.

Jeg tror nu, at min kode oplever et stort ydeevnetab, da hver observatør skal filtrere hver værdi, der udsendes. Eller rettere, et nyt filtreret observable oprettes hver gang, jeg har brug for, at en ny observatø

Læs mere →

typescript - Angular 6 - rxjs-egenskaben 'map' findes ikke på typen 'observable'

Får denne fejl, når jeg opgraderede til Angular 6. Jeg ser dokumentationen for at bruge .pipe(), men jeg forstår ikke, hvordan man bruger pipe, når der er flere .map() som nedenfor. Har brug for din hjælp...

import {Injectable} from '@angular/core'; import {Http, Header

Læs mere →

typescript - RxJS fromEventPattern med React Native-begivenheder

Jeg forsøger at filtrere native events i React Native med RxJS. Jeg bruger react-native-ble-manager, som eksponerer en EventEmitter. Grundlæggende gør jeg følgende uden RxJS (kun den relevante kode vises her):

import React from 'react'; import RX from 'reactxp'; import { AppState, Platform, NativeModules, NativeEventEmitter, EmitterSubscription, PermissionsAndroid, ListView } from 'react-native'; import BleManager, { Peripheral } from 'react-native-ble-manager';

Læs mere →

javascript - Er der en måde at tilmelde sig igen efter at have afmeldt RxJS?

Her er et eksempel på kode, der abonnerer på en Http-anmodning og annullerer den ved klik med musen på siden. Jeg vil gerne abonnere igen, hvis jeg klikker igen.

Hvordan kan jeg skifte abonnement? FIDDLE

export class AboutComponent implements OnInit { constructor(private http:HttpCl

Læs mere →

angular - RxJS/Observable: Hvordan man sætter rækkefølge for pipe-metoder

Jeg har en metode run i klassen Some, som returnerer Observable og har pipe inde i denne metode. Og jeg har endnu en pipe, når jeg udfører metoden run.

import { of } from 'rxjs'; import { map, tap, delay } from 'rxjs/operators';

Læs mere →

javascript - Leder efter noget som OrElse i Angular RxJS find-funktion, mens der pipe's

Jeg har fået følgende stykke kode. Det, jeg prøver at opnå, er at omdirigere til siden ikke fundet, når "find"-funktionen ikke finder nogen ordreobjekt i de observerbare indlæste ordrer.

private order: Observable<OrderModel>; ngOnInit() {

Læs mere →

angular - Hvordan man bruger rxjs "find" operatoren

Jeg vil sætte nameMatch til nodeName, hvis nodeName er til stede i den observerbare strøm. Det samme med idMatch. Jeg prøver at bruge find rxjs-operatoren. Dette er, hvad jeg har lige nu:

const response = (this._resourceService.search(ResourceUrns.SERVICE_METRIC) .pipe( map(getServiceNodes)) .subscribe(result => { if (result.find(nodeName)){

Læs mere →

angular - Rxjs timeout() kaster fejl for nogle fremtidige datoer

Rxjs timeout() fungerer ikke korrekt for nogle Dage eller Tidsstempel

import { interval } from 'rxjs'; import { timeout } from 'rxjs/operators'; const seconds = interval(1000); seconds.pipe( // Present Date (Thu Mar 19 2020 14:40:58) => 1584628858530 // to UTC time & date: (Wed Dec 30 2020 18:30:00) => 1609353000000-------Not working // to UTC time & date: (Mon Dec 30 2030 18:30:00) => 1924885800000-------Working timeo

Læs mere →

typescript - RxJS - Konverter løfte-kæde til observable virker ikke

Jeg prøver at konvertere løftekædning:

this.tradeTypesLogicService.getList().$promise .then(this.filterTradeTypes) .then(this.setSelectedTradeType)

til en rxjs-observable:

this.tradeTypesLogicService .getList() //returns observable now .pipe(mergeMap(this.filterTradeTypes), map(this.setSelectedTradeType)) .subscribe(); protected filterTradeTypes = (tradeTypes: Array<any>) => { this.tradeTypes = filter(tradeTypes,

Læs mere →