javascript - RXJS Angular - Kuinka kutsua funktiota foreach-silmukan lopussa, joka sisältää observables?
this.attachmentList.forEach((attachment, i) => {
this.service.getPageOfAttachment().flatMap(response =>
this.service.download((JSON.parse(response['Content']).mediaUrl)))
.subscribe(response => {
}, error =&g
Lue lisää →
javascript - Kuinka valikoivasti lähettää kuumia (jaettuja) observables RxJS:ssä?
Koodissani minulla on kuuma observable (kylmä observable, joka on putkistettu share()-operaattorin läpi), joka lähettää arvoja tunnisteiden kanssa (eli datapaketin tyyppi sisältää "id"-merkkijonomuuttujan). Useat havainnoijat suodattavat sitten lähetetyt arvot kyseisen id:n perusteella.
Nyt luulen, että koodini ottaa suuren suorituskykyiskun, koska jokaisen havainnoijan täytyy suodattaa jokainen arvo, joka lähetetään. Tai oikeastaan joka kerta, kun tarvitsen uuden havaitsijan tilaamaan
Lue lisää →typescript - Angular 6 - rxjs-ominaisuutta 'map' ei ole tyypissä 'observable'
Saan tämän virheen, kun päivitin Angular 6:een. Näen dokumentaation käyttääkseni .pipe(), mutta en ymmärrä, miten käyttää pipea, kun on useita .map()-kutsuja kuten alla. Tarvitsen apuasi...
import {Injectable} from '@angular/core'; import {Http, Headers} from '@angular/ Lue lisää →typescript - RxJS fromEventPattern React Native -tapahtumien kanssa
Yritän suodattaa natiiveja tapahtumia React Nativen sisällä käyttämällä RxJS:ää. Käytän react-native-ble-manageria, joka tarjoaa EventEmitterin. Periaatteessa teen seuraavaa ilman RxJS:ää (näkyvissä on vain oleellisin koodi):
import React from 'react'; import RX from 'reactxp'; import { AppState, Platform, NativeModules, NativeEventEmitter, EmitterSubscription, PermissionsAndroid, ListView } from 'react-native'; import BleManager, { Peripheral } from 'react-nati Lue lisää →javascript - Onko tapaa uudelleen-tilaamiseen RxJS:ssä sen jälkeen kun on perunut tilauksen?
Tässä on esimerkkikoodi, joka tilaa HTTP-pyynnön ja peruuttaa sen, kun hiirtä klikataan sivulla. Haluaisin tilata sen uudelleen, jos suoritan klikkauksen uudelleen.
Kuinka voin vaihtaa tilausta? FIDDLE
export class AboutComponent implements OnInit { constructor(private http:HttpClie Lue lisää →angular - RxJS/Observable: Kuinka asettaa järjestys pipe-menetelmille
Minulla on metodi run luokassa Some, joka palauttaa Observable-objektin ja sisältää pipe-funktion tässä metodissa. Ja minulla on vielä yksi pipe, kun suoritan metodin run.
import { of } from 'rxjs'; import { map, tap, delay } fro Lue lisää →javascript - Etsin jotain sellaista kuin OrElse Angularin rxjs find -funktiossa putkitettaessa
Minulla on seuraava koodinpätkä. Mitä yritän saavuttaa, on uudelleenohjata sivulle ei löydy, kun "find"-funktio ei löydä yhtään tilausta havaittavissa ladatuissa tilauksissa.
private order: Observable<OrderModel>; ngOnInit() { Lue lisää →angular - Kuinka käyttää rxjs:n "find"-operaattoria
Haluan asettaa nameMatch arvoksi nodeName, jos nodeName on läsnä havaittavassa virrassa. Sama koskee idMatch-arvoa. Yritän käyttää find-rxjs-operaattoria. Tällä hetkellä minulla on tämä:
const response = (this._resourceService.search(ResourceUrns.SERVICE_METRIC) .pipe( map(getServiceNodes)) .subscribe(result => { if (result.find(nodeName)){ Lue lisää →angular - Rxjs timeout() heittää virheen joillekin tuleville päivämäärille
Rxjs timeout() ei toimi oikein joillekin päiville tai aikaleimalle
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( Lue lisää →typescript - RxJS - Muunna lupausketju havaittavaksi ei toimi
Yritän muuntaa lupauksen ketjuttamisen:
this.tradeTypesLogicService.getList().$promise .then(this.filterTradeTypes) .then(this.setSelectedTradeType)rxjs-havaittavaan:
this.tradeTypesLogicService .getList() //returns observable now .pipe(mergeMap(this.filterTradeTypes), map(this.setSelectedTradeType)) .subscribe(); protected filterTradeTypes = (tradeTypes: Array<any>) => { this.tradeTypes = filter(tradeTypes, (tra Lue lisää →