javascript - RXJS Angular - Come chiamare una funzione alla fine di un ciclo foreach che contiene observables?

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

Continua a leggere →

javascript - Come emettere selettivamente osservabili caldi (condivisi) in RxJS?

Nel mio codice, ho un observable hot (observable cold passato attraverso l'operatore share()) che emette valori con identificatori (cioè il tipo di payload contiene una proprietà stringa "id"). Un gruppo di observer su questo poi filtra i valori emessi basandosi sul suddetto id.

Ora penso che il mio codice stia subendo un enorme calo di prestazioni, poiché ogni osservatore deve filtrare ogni valore che viene emesso. O meglio, viene creato un nuovo osservabile filtrato ogni volta che ho

Continua a leggere →

typescript - Angular 6 - rxjs proprietà 'map' non esiste sul tipo 'observable'

Ricevo questo errore quando ho aggiornato ad Angular 6. Vedo la documentazione per usare .pipe(), ma non capisco come usare pipe quando ci sono più .map() come di seguito. Ho bisogno del tuo aiuto...

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

Continua a leggere →

typescript - RxJS fromEventPattern con eventi di React Native

Sto cercando di filtrare gli eventi nativi in React Native con RxJS. Sto usando react-native-ble-manager che espone un EventEmitter. Fondamentalmente, senza RxJS sto facendo quanto segue (qui viene mostrato solo il codice rilevante):

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

Continua a leggere →

javascript - Esiste un modo per risottoscriversi dopo aver annullato l'iscrizione in RxJS?

Ecco un esempio di codice che si iscrive a una richiesta Http e la annulla al clic del mouse sulla pagina. Vorrei risottoscrivere se faccio clic nuovamente.

Come posso attivare/disattivare l'abbonamento? FIDDLE

export class AboutComponent implements OnInit { constructor(private htt

Continua a leggere →

angular - RxJS/Observable: Come impostare l'ordine per i metodi pipe

Ho un metodo run nella classe Some che restituisce un Observable e ha pipe all'interno di questo metodo. E ho un altro pipe quando eseguo il metodo run.

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

Continua a leggere →

javascript - Cercando qualcosa come OrElse nella funzione find di angular rxjs durante il piping

Ho il seguente pezzo di codice. Quello che sto cercando di ottenere è reindirizzare alla pagina non trovata quando la funzione "find" non trova alcun oggetto ordine negli ordini caricati nell'observable.

private order: Observable<OrderModel>

Continua a leggere →

angular - Come usare l'operatore rxjs "find"

Voglio impostare nameMatch su nodeName se nodeName è presente nello stream osservabile. Lo stesso vale per idMatch. Sto cercando di usare l'operatore find di rxjs. Questo è quello che ho attualmente:

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

Continua a leggere →

angular - Rxjs timeout() sta generando un errore per alcune date future

Rxjs timeout() non funziona correttamente per alcuni Giorni o 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 tim

Continua a leggere →

typescript - RxJS - Conversione di una catena di promise in observable non funzionante

Sto cercando di convertire il concatenamento delle promise:

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

a un observable di RxJS:

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

Continua a leggere →