Resultados de la búsqueda a petición "rxjs"
¿Cómo darse de baja / detener Observable?
Yo uso el siguiente código para el temporizador: export class TimerService { private ticks: number = 0; private seconds: number = 0; private timer; constructor(seconds: number) { this.seconds = seconds; this.timer = Observable.timer(2000, 1000); ...
hacer (tap) vs suscribirse
Editar: Antes de RxJs 6,tap fue llamado comodo . Título actualizado para reflejar el toque también. Me gustaría entender cuál es la mejor práctica de usar.subscribe y.do métodos de observables. Por ejemplo, si necesito hacer un trabajo después ...
Angular: ¿cuál es la forma preferida de terminar los Observables?
Según tengo entendido, Angular y RxJs hay dos formas de terminar los Observables. Usted puedeunsubscribe() de ellos o usartakeUntil() ycomplete(). A continuación se muestran ejemplos de cada enfoque (en pseudocódigo). El enfoque unsubscribe ...
¿Cómo obtener eventos observables RxJS en tiempo cero?
Estoy recopilando todos los eventos de un observable a undata formación: const obs$ = Rx.Observable .interval(500) .take(4); let data = []; const start = performance.now(); obs$.subscribe( value => { data.push({ time: performance.now() - ...
Error: el temporizador de propiedad no existe en el tipo typeof Observable
El codigo esta abajo import {Component} from 'angular2/core'; import {Observable} from 'rxjs/Rx'; @Component({ selector: 'my-app', template: 'Ticks (every second) : {{ticks}}' }) export class AppComponent { ticks =0; click(){ let timer ...
¿Por qué jest.useFakeTimers no funciona con RxJs? Observable delay
Me pregunto por quéjest.useFakeTimers está trabajando consetTimeout pero no con el operador de retraso de RxJs: jest.useFakeTimers(); import {Observable} from 'rxjs/Observable'; import 'rxjs'; describe('timers', () => { it('should resolve ...
Pipe RxJS observable al sujeto existente
Hay un tema existente que está en uso: const fooSubject = new BehaviorSubject(null);Y hay otro observable (otro tema en este ejemplo): const barSubject = new Subject(); barSubject.subscribe( value => fooSubject.next(), err => ...
¿Cómo limitar la concurrencia de flatMap?
Estoy tratando de usar RxJS para escribir un script para procesar varios cientos de archivos de registro, cada uno de los cuales tiene aproximadamente 1 GB. El esqueleto del guión se parece a Rx.Observable.from(arrayOfLogFilePath) ...
¿Necesitamos cancelar la suscripción a las llamadas http en Angular? [duplicar]
Esta pregunta ya tiene una respuesta aquí: ¿Es necesario darse de baja de los observables creados por los métodos Http? [/questions/35042929/is-it-necessary-to-unsubscribe-from-observables-created-by-http-methods] 7 respuestasProbablemente una ...
Suscriptor RxJS darse de baja vs. completo
Estaba leyendo los documentos de RxJS y quiero asegurarme de que entiendo la diferencia entreSubscriber.unsubscribe() ySubscriber.complete(). Digamos que tengo un observable con dos suscriptores, suscriptor1 y suscriptor2. Si el suscriptor1 ...