javascript - RXJS Angular - Hur man kallar en funktion i slutet av en foreach-loop som innehåller 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 mer →

javascript - Hur man selektivt emitterar heta (delade) observables i RxJS?

I min kod har jag en het observable (kall observable pipad genom share()-operatorn) som avger värden med identifierare (dvs. payload-typen innehåller en "id"-strängs egenskap). Ett gäng observatörer på detta filtrerar sedan de avgivna värdena baserat på nämnda id.

Jag tror nu att min kod får en stor prestandapåverkan, eftersom varje observatör måste filtrera varje värde som sänds ut. Eller snarare, ett nytt filtrerat observerbart skapas varje gång jag behöver att en ny observatör ska pr

Läs mer →

typescript - Angular 6 - rxjs-egenskapen 'map' finns inte på typen 'observable'

Får detta felmeddelande när jag uppgraderade till Angular 6. Jag ser dokumentationen för att använda .pipe(), men jag förstår inte hur man använder pipe när det finns flera .map() som nedan. Behöver din hjälp...

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

Läs mer →

typescript - RxJS fromEventPattern med React Native-händelser

Jag försöker filtrera inbyggda händelser i React Native med RxJS. Jag använder react-native-ble-manager som exponerar en EventEmitter. I princip, utan RxJS gör jag följande (endast relevant kod visas här):

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'; co

Läs mer →

javascript - Finns det ett sätt att prenumerera på nytt efter att ha avprenumererat RxJS?

Här är ett exempel på kod som prenumererar på HTTP-förfrågan och avbryter den vid musklick på sidan. Jag skulle vilja prenumerera igen om jag klickar en gång till.

Hur kan jag växla prenumeration? FIDDLE

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

Läs mer →

angular - RxJS/Observable: Hur man sätter ordning för pipe-metoder

Jag har en metod run i klassen Some som returnerar Observable och har pipe inuti denna metod. Och jag har en till pipe när jag kör metoden run.

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

Läs mer →

javascript - Letar efter något som OrElse i Angular RxJS find-funktion medan jag använder piping

Jag har fått följande kodstycke. Vad jag försöker åstadkomma är att omdirigera till sidan för inte hittad när funktionen "find" inte hittar något orderobjekt i de observerbara laddade ordrarna.

private order: Observable<OrderModel>; ngOnIni

Läs mer →

angular - Hur man använder rxjs "find"-operatören

Jag vill sätta nameMatch till nodeName om nodeName finns i det observerbara flödet. Samma sak med idMatch. Jag försöker använda find rxjs-operatören. Detta är vad jag har just nu:

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

Läs mer →

angular - Rxjs timeout() kastar fel för vissa framtida datum

Rxjs timeout() fungerar inte korrekt för vissa Days eller Timestamp

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 timeout

Läs mer →

typescript - RxJS - Konvertera löfteskedja till observable fungerar inte

Jag försöker konvertera löfte-kedjning:

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

till ett rxjs-observable:

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

Läs mer →