javascript - RXJS Angular - Comment appeler une fonction à la fin d'une boucle foreach qui contient des observables ?

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

Lire la suite →

javascript - Comment émettre sélectivement des observables chauds (partagés) dans RxJS ?

Dans mon code, j'ai un observable chaud (observable froid passé par l'opérateur share()) émettant des valeurs avec des identifiants (c'est-à-dire que le type de charge utile contient une propriété de chaîne « id »). Plusieurs observateurs filtrent ensuite les valeurs émises en fonction de cet id.

Je pense maintenant que mon code subit une énorme perte de performance, puisque chaque observateur doit filtrer chaque valeur qui est émise. Ou plutôt, un nouvel observable filtré est créé chaq

Lire la suite →

typescript - Angular 6 - rxjs propriété 'map' n'existe pas sur le type 'observable'

Je reçois cette erreur lorsque j'ai mis à niveau vers Angular 6. Je vois la documentation pour utiliser .pipe(), mais je ne comprends pas comment utiliser pipe lorsqu'il y a plusieurs .map() comme ci-dessous. J'ai besoin de votre aide...

import {Injectable} from '@angular/c

Lire la suite →

typescript - RxJS fromEventPattern avec les événements React Native

J'essaie de filtrer les événements natifs dans React Native avec RxJS. J'utilise react-native-ble-manager qui expose un EventEmitter. Fondamentalement, sans RxJS je fais ce qui suit (seulement le code pertinent est montré ici) :

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

Lire la suite →

javascript - Y a-t-il un moyen de se réabonner après s'être désabonné de RxJS ?

Voici un exemple de code qui s'abonne à une requête Http et l'annule lors d'un clic de souris sur la page. Je voudrais me réabonner si je clique à nouveau.

Comment puis-je basculer l'abonnement ? FIDDLE

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

Lire la suite →

angular - RxJS/Observable : Comment définir l'ordre pour les méthodes pipe

J'ai une méthode run dans la classe Some qui retourne un Observable et qui contient un pipe à l'intérieur de cette méthode. Et j'ai un autre pipe lorsque j'exécute la méthode run.

import { of } from 'rxjs'; import { map, tap, del

Lire la suite →

javascript - À la recherche de quelque chose comme OrElse dans la fonction find de rxjs d'Angular lors de l'utilisation de pipe

J'ai le morceau de code suivant. Ce que j'essaie de faire, c'est rediriger vers la page introuvable lorsque la fonction « find » ne trouve aucun objet commande dans les commandes chargées observables.

private order: Observable<OrderModel>;

Lire la suite →

angular - Comment utiliser l'opérateur rxjs « find »

Je veux définir nameMatch sur le nodeName si le nodeName est présent dans le flux observable. Il en va de même pour idMatch. J'essaie d'utiliser l'opérateur find de rxjs. Voici ce que j'ai actuellement :

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

Lire la suite →

angular - Rxjs timeout() génère une erreur pour certaines dates futures

Rxjs timeout() ne fonctionne pas correctement pour certains Jours ou Horodatage

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-------Worki

Lire la suite →

typescript - RxJS - Conversion d'une chaîne de promesses en observable ne fonctionne pas

J'essaie de convertir le chaînage de promesses :

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

à un observable RxJS :

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

Lire la suite →