En la página de documentación de Angular 2 para usar el servicio Http, hay un ejemplo. getHeroes (): Observable<Stuff[]> { return this.http.get(this.url) .map(this.extractData) .catch(this.handleError); } Cloné el proyecto angular2-webpack-starter y agregué el código anterior. Importé...
He estado buscando entender esos 3: Asunto , Asunto de comportamiento y Asunto de repetición . Me gustaría usarlos y saber cuándo y por qué, cuáles son los beneficios de usarlos y, aunque he leído la documentación, he visto tutoriales y he buscado en Google, no he podido entender esto. Entonces,...
Tengo un servicio que tiene este método: export class TestModelService { public testModel: TestModel; constructor( @Inject(Http) public http: Http) { } public fetchModel(uuid: string = undefined): Observable<string> { if(!uuid) { //return Observable of JSON.stringify(new...
¿Alguien puede dar una definición clara junto con un ejemplo simple que explique qué es un "infierno de devolución de llamada" para alguien que no conoce JavaScript y node.js? ¿Cuándo (en qué tipo de configuración) ocurre el "problema del infierno de devolución de llamada"? ¿Por qué ocurre? ¿El...
Sé que Redux es una mejor "implementación" de Flux, o mejor dicho, es un rediseño para simplificar las cosas (administración del estado de la aplicación). He escuchado mucho sobre la programación reactiva (RxJS), pero aún no me he sumergido para aprenderlo. Entonces mi pregunta es: ¿hay alguna...
Las tuberías son filtros para transformar datos (formatos) en la plantilla. Encontré la pipe()función de la siguiente manera. ¿Qué significa pipe()exactamente esta función en este caso? return this.http.get<Hero>(url) .pipe( tap(_ => this.log(`fetched hero id=${id}`)),...
Me gustaría poder esperar en un observable, p. Ej. const source = Rx.Observable.create(/* ... */) //... await source; Un intento ingenuo da como resultado que la espera se resuelva de inmediato y no bloquee la ejecución. Editar: El pseudocódigo para mi caso de uso previsto completo es: if...
De acuerdo con este artículo , onCompletey la onErrorfunción de los subscribeson mutuamente excluyentes. Es decir, onErroro los onCompleteeventos se dispararán en mi subscribe. Tengo un bloque lógico que debe ejecutarse si recibo un error o si termino mi flujo de información con éxito. Busqué...
Creo que tengo el concepto base, pero hay algunas oscuridades Entonces, en general, así es como uso un observable: observable.subscribe(x => { }) Si quiero filtrar datos, puedo usar esto: import { first, last, map, reduce, find, skipWhile } from 'rxjs/operators'; observable.pipe( map(x...
En una aplicación angular, tenemos un ngOnDestroy()gancho de ciclo de vida para un componente / directiva y usamos este gancho para cancelar la suscripción de los observables. Quiero claros / destructores observables que se crean en un @injectable()servicio. Vi algunas publicaciones que decían que...
No sé cómo extraer valor de Observable para que lo devuelva la función en la que Observable está presente. Necesito solo un valor de él para ser devuelto, nada más. Versión actual que funciona function getValueFromObservable() { this.store.subscribe( (data:any) => { console.log(data) }...
Actualmente estoy tratando de aprender Angular2 y TypeScript después de trabajar felizmente con AngularJS 1. * durante los últimos 4 años. Tengo que admitir que lo odio, pero estoy seguro de que mi momento eureka está a la vuelta de la esquina ... de todos modos, he escrito un servicio en mi...
Cuando ejecuto el linter, dice: subscribe is deprecated: Use an observer instead of an error callback Código (de una aplicación angular 7 con angular-cli): this.userService.updateUser(data).pipe( tap(() => {bla bla bla}) ).subscribe( this.handleUpdateResponse.bind(this),...
Quiero lanzar un error del operador de mapa de mi observable basado en una condición. Por ejemplo, si no se reciben los datos de API correctos. Consulte el siguiente código: private userAuthenticate( email: string, password: string ) { return
Estoy tratando de entender cómo usar Observables en Angular 2. Tengo este servicio: import {Injectable, EventEmitter, ViewChild} from '@angular/core'; import {Observable} from "rxjs/Observable"; import {Subject} from "rxjs/Subject"; import {BehaviorSubject} from "rxjs/Rx"; import...
Estoy empezando a usar RxJS y no entiendo por qué en este ejemplo necesitamos usar una función como flatMapo concatAll; ¿Dónde está la matriz de matrices aquí? var requestStream = Rx.Observable.just('https://api.github.com/users'); var responseMetastream = requestStream
Extraje un código de plantilla de muestra de este tutorial e hice los siguientes dos pasos para comenzar: npm install // worked fine and created node_modules folder with all dependencies npm start // falló con el siguiente error- node_modules/rxjs/Subject.d.ts(16,22): error TS2415: Class...
Digamos que tengo un Observable, así: var one = someObservable.take(1); one.subscribe(function(){ /* do something */ }); Entonces, tengo un segundo Observable: var two = someOtherObservable.take(1); Ahora, quiero subscribe()a two, pero yo quiero para asegurarse de que onese ha completado...
Me pregunto cuáles son las diferencias entre Observable.combineLatesty Observable.forkJoin. Por lo que puedo ver, la única diferencia es que forkJoinespera que los Observables se completen, mientras combineLatestdevuelve los últimos valores.
Me pregunto cuál es el uso de asObservable: Según los documentos: Una secuencia observable que oculta la identidad de la secuencia fuente. Pero, ¿por qué necesitarías ocultar la secuencia?