Articles of rxjs

Il servizio Http di Angular 2 non espone map () e altre funzioni RxJS

Qualcuno sa se sono state apportate modifiche irrisolte al http tra alpha 45 e alpha 48? Ho cercato in giro e non ho trovato nulla. Il mio problema è che il codice sotto funzionava perfettamente su Alpha 45. Ma ora che ho aggiornato a Alpha 48 sto ottenendo una _this.http.post(…).map is not a function messaggio […]

La sequenza RxJS equivale a promise.then ()?

Ho sviluppato molte promesse e ora mi trasferisco su RxJS. Il documento di RxJS non fornisce un esempio molto chiaro su come passare dalla sequenza di promesse alla sequenza di osservatori. Ad esempio, di solito scrivo una catena di promesse con più passaggi, come // a function that returns a promise getPromise() .then(function(result) { // […]

Chaining Observables in RxJS

Sto imparando RxJS e Angular 2. Diciamo che ho una catena di promesse con più chiamate di funzioni asincrone che dipendono dal risultato precedente che assomiglia a: var promiseChain = new Promise((resolve, reject) => { setTimeout(() => { resolve(1); }, 1000); }).then((result) => { console.log(result); return new Promise((resolve, reject) => { setTimeout(() => { resolve(result […]

Angular 4 Interceptor esegue nuovamente le richieste dopo l’aggiornamento del token

Ciao Sto cercando di capire come implementare i nuovi intercettori angolari e gestire 401 unauthorized errori 401 unauthorized aggiornando il token e riprovando la richiesta. Questa è la guida che ho seguito: https://ryanchenkie.com/angular-authentication-using-the-http-client-and-http-interceptors Sto memorizzando correttamente nella cache le richieste non riuscite e posso aggiornare il token ma non riesco a capire come inviare nuovamente […]

Sottoscrizione a osservabile nidificato

Ho un’app che effettua una richiesta http per ottenere un elenco di elementi e quindi effettua una richiesta http per ciascun elemento nell’elenco per ottenere informazioni più dettagliate su ciascun elemento. effettivamente: class ItemsService { fetchItems() { return this.http.get(url) .map(res => res.json()) .map(items => items.map(this.fetchItem(item))); } fetchItem(item: Item) { this.http.get(`${url}/${item.id}`) .map(res => res.json()); } } […]

Unisci sottoarray usando Observables

Ho questa struttura dati: [{ id : 1, name : “Item 1”, subItems : [{ id : 1, name : “SubItem 1” },{ id : 2, name : “SubItem 2” } ] }, { id : 2, name : “Item 2”, subItems : [{ id : 3, name : “SubItem 3” }, { id : […]

RxJS: takeUntil () Il componente angular ngOnDestroy ()

tl; dr: Fondamentalmente voglio sposare il ngOnDestroy di ngOnDestroy con l’operatore takeUntil() . — è ansible? Possiedo un componente Angolare che apre diverse sottoscrizioni Rxjs. Questi devono essere chiusi quando il componente viene distrutto. Una soluzione semplice per questo sarebbe: class myComponent { private subscriptionA; private subscriptionB; private subscriptionC; constructor( private serviceA: ServiceA, private serviceB: […]

Passare dati con soggetti e proxy

È ansible avere un stream di dati a 2 vie utilizzando Soggetti in un servizio? Supponiamo ad esempio che io voglia che alcuni componenti recuperino le informazioni e quindi pubblichino attraverso il Sobject del servizio perché un altro componente possa consumare. Il componente consumante apporta quindi alcune modifiche a queste informazioni e quindi le reinserisce […]

Come forzare gli osservabili ad eseguire in sequenza?

Mi sto spostando dal mondo promesso al mondo osservabile. Una cosa che faccio di solito con Promise è concatenare una serie di attività e farle funzionare in sequenza. Ad esempio, ho tre compiti: printLog1() per stampare 1 sulla console, printLog23() per stampare 2 e 3 sulla console e printLog4() per stampare 4. Quando voglio stampare […]

Gestire i token di aggiornamento usando rxjs

Da quando ho iniziato con angular2 ho impostato i miei servizi per restituire Observable of T. Nel servizio avrei la chiamata a map (), e i componenti che usano questi servizi useranno semplicemente subscribe () per attendere la risposta. Per questi semplici scenari non avevo davvero bisogno di scavare in rxjs quindi tutto andava bene. […]