Resultados de la búsqueda a petición "rxjs"
Como esperar a los guardias en Angular
Si especifico tres guardias en una ruta, parece que todos los guardias son evaluados de inmediato. {path: '', component: OptionsComponent, canActivate: [ GuardOne, GuardTwo, GuardThree]} El problema que tengo es que no quieroGuardTwo correr ...
cómo hacer 2 solicitudes http dependientes en Angular 2
Necesito hacer 2 solicitudes http (la segunda depende de la primera) para insertar credenciales de usuario en mi base de datos. el primer servicio obtiene las credenciales de usuario (http: // localhost: 55978 / FleetViewDBWebService.asmx / ...
Angular 2: suscripción al error Observable.fromEvent: "Objetivo de evento no válido"
Recibo un error extraño al intentar suscribirme a un Observable. Aquí hay una versión diluida del código que presenta el problema: import {Component, Input, OnInit, ViewChild} from '@angular/core'; import Rx from 'rxjs/Rx'; @Component({ ...
Angular 2 - Temporizador de cuenta regresiva
Estoy dispuesto a hacer un temporizador de cuenta regresiva en Angular 2 que comience desde 60 (es decir, 59, 58,57, etc.) Para eso tengo lo siguiente: constructor(){ Observable.timer(0,1000).subscribe(timer=>{ this.counter = timer; }); }Lo ...
Angular - HttpClient: Resultado del objeto del método Get Map a la propiedad de matriz
Estoy llamando a una API que devuelve un objeto JSON. Solo necesito el valor de la matriz para asignar a un Observable. Si llamo a una API que solo devuelve la matriz, mi llamada de servicio funciona. A continuación se muestra mi código de ...
Utilice una promesa en Angular HttpClient Interceptor
¿Puedo usar promesa dentroHttpInterceptor? Por ejemplo: export class AuthInterceptor implements HttpInterceptor{ this.someService.someFunction() .then((data)=>{ //do something with data and then return next.handle(req); }); }¿Por qué necesito ...
RxJS: takeUntil () componente angular ngOnDestroy ()
tl; dr: Básicamente quiero casarme con AngularngOnDestroy con los RxjstakeUntil() operador. -- ¿es eso posible? Tengo un componente angular que abre varias suscripciones Rxjs. Estos deben cerrarse cuando se destruye el componente. Una solución ...
Debounce el evento @HostListener
Estoy implementando una directiva simple de desplazamiento infinito en Angular2. Estoy usando@HostListener('window:scroll') para obtener el evento de desplazamiento y analizar los datos del$target. La pregunta es, para cada evento de ...
RxJS takeWhile pero incluye el último valor
Tengo una tubería RxJS5 que se ve así Rx.Observable.from([2, 3, 4, 5, 6]) .takeWhile((v) => { v !== 4 })Quiero mantener la suscripción hasta que vea 4, pero quiero que el último elemento 4 también se incluya en el resultado. Entonces el ejemplo ...
RxJS Observable con función de suscriptor asíncrono
Estoy tratando de hacer algo que parece que debería ser sencillo, pero está resultando sorprendentemente difícil. Tengo una función para suscribirme a una cola RabbitMQ. Concretamente, esta es la función Channel.consume ...