rxjs

En Angular 2 usando rxjs estaba tratando de convertir una Promesa a Observable. Como muchas de las guías en línea mostraron u ... se is not a function Se informó de un problema algo similar en el repositorio rxjs aquí pero no hay solución allí tampoco.

He estado golpeando mi cabeza contra este tratando de averiguarlo, y ninguna cantidad de documentación que he podido leer me ... , ¿cuál es la alternativa? Agregaré que el _restService es bastante confiable y realmente no quiero comenzar a jugar con eso.

En una aplicación angular tenemos ngOnDestroy() gancho de ciclo de vida para un componente / directiva y usamos este gancho p ... usar en un servicio. Pero, ¿es una buena práctica y la única manera de hacerlo y Cuándo se llamará ? que alguien lo aclare.

Estoy empujando observables en una matriz como tal... var tasks$ = []; tasks$.push(Observable.timer(1000)); tasks$.push(Obse ... ie de preguntas SO, pero todas parecen lidiar con la espera de un número conocido de flujos (por ejemplo, mapearlos juntos).

Estoy tratando de usar el método de intervalo de un observable, pero sigo recibiendo el error Property 'interval' does not ... estas importaciones: import "rxjs/Rx"; import "rxjs/add/observable/interval"; import "rxjs/observable/IntervalObservable";

Estoy trabajando en una aplicación Angular 2 y necesito alguna guía sobre cómo manejar los errores de autenticación de forma ... l, (error: Response) => { // Do some nifty error handling here. }); return sharable; } }

Digamos que tengo un Observable, así: var one = someObservable.take(1); one.subscribe(function(){ /* do something */ }); ... hacer que el segundo espere a que se complete el primero? Supongo que estoy buscando pausar two hasta que one esté completo.

Estoy migrando una aplicación Angular 5 a la última CLI y Angular 6 RC y todas mis importaciones observables están rotas. Veo ... én lanza un error de compilación cuando se usa en código. ¿Alguien tiene una referencia a cómo se supone que funciona esto?

Siendo nuevo en RxJS a menudo creo un sujeto que mantiene valores en el futuro, pero es inicialmente undefined. Solo puede se ... t.filter(function(value) { return value !== undefined; }).subscribe(function(value) { // do something with the value });

Estoy migrando a [email protected] y usando operadores lettables... También actualizo Observable métodos estáticos. Me pregunto ¿cuá ... ora parece que todos los métodos de creación estáticos como of, from ¿debe importarse de rxjs/observable/<methodName> ?

Tengo una secuencia RxJS consumiéndose de la manera normal... Sin embargo, en el controlador observable 'onNext', algunas de ... (error) { console.log('error'); }, function onComplete() { console.log('complete'); } );

Estoy buscando la manera de enviar múltiples acciones redux en una única Epic de redux-observable middleware. Asumamos que ... se. Esto me parece un poco feo. Entonces, mi pregunta: ¿Hay una manera de enviar múltiples acciones redux en una sola épica?

En mi plantilla de componente estoy llamando a async pipe para el mismo Observable en 2 lugares. ¿Debo suscribirme a él y u ... tubería async para el mismo Observable en varios lugares de la plantilla no tiene ningún efecto negativo para el rendimiento?

No está 100% claro para mí cómo funciona el operador RxJS 5 share(), vea aquí los últimos documentos . Jsbin para la pregunt ... l share(). ¿Qué está pasando aquí, cómo funciona el operador share()? ¿Cada suscripción crea una nueva cadena Observable?

Me gustaría emitir un solo valor. De acuerdo con este post , lo siguiente debe ser válido: var requestStream = Rx.Observab ... m/users'); Sin Embargo, esto no funciona. just no está definido. ¿Ha sido obsoleto? ¿Hay algo que pueda usar en su lugar?