Resultados de la búsqueda a petición "rxjs"
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 importar correctamente operadores desde el paquete `rxjs`
Estoy confundido sobre cómo importar esos operadores. Algunos puedo importar conimport 'rxjs/add/operator/do'; y algunos no puedo. Por ejemplo, esto no funciona:import 'rxjs/add/operator/map'; (Verifiqué en rxjs / add / operator, el mapa existe ...
¿Cómo puedo 'esperar' en un Rx Observable?
Me gustaría poder esperar en un observable, p. const source = Rx.Observable.create(/* ... */) //... await source;Un intento ingenuo hace que la espera se resuelva de inmediato y no bloquee la ejecución Editar: El pseudocódigo para mi caso de ...
¿Cómo pruebo una función que devuelve un observable usando intervalos temporizados en rxjs 5?
Por ejemplo, tengo una función como esta: export function timeRange(start: number, end: number): Rx.Observable<number> { return Rx.Observable.interval(1000) .map(n => n + start) .take(end - start + 1) }Y tuve una prueba unitaria que ejecutó ...
Tareas dependientes de colas RxJS
Si tengo una matriz de matrices como esta { parent: [ { name: 'stu', children: [ {name: 'bob'}, {name: 'sarah'} ] }, { ... } ] }y quiero pasar por cada padre y pasar por sus hijos en serie, para no comenzar el próximo padre hasta que todos los ...
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 ...
RxJs: sondeo hasta que se realiza el intervalo o se reciben los datos correctos
¿Cómo ejecuto el siguiente escenario en el navegador con RxJs: enviar datos a la cola para su procesamientorecuperar la identificación del trabajosondee otro punto final cada 1s hasta que el resultado esté disponible o hayan transcurrido 60 ...
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 ...
La propiedad 'toPromise' no existe en el tipo 'Observable <Response>'
import { Headers, Http } from '@angular/http'; @Injectable() export class PublisherService{ private publishersUrl = 'app/publisher'; constructor(private http: Http) { } getPublishers(): Promise<Publisher[]>{ ...
Tenedor observable Únete sin disparar
Estoy tratando de usarforkJoin en dos observables. Uno de ellos comienza como una secuencia ... Si me suscribo directamente a ellos, recibo una respuesta,forkJoin aunque no dispara. ¿Algunas ideas? private data$: Observable<any[]>; private ...