Preguntas etiquetadas con rxjs

Reactive Extensions for JavaScript (RxJS) es un conjunto de bibliotecas para componer programas asincrónicos y basados ​​en eventos utilizando colecciones observables y composición de estilo Array Extras.

690
BehaviorSubject vs Observable?

Estoy investigando los patrones de Angular RxJs y no entiendo la diferencia entre a BehaviorSubjecty an Observable. Según tengo entendido, a BehaviorSubjectes un valor que puede cambiar con el tiempo (puede suscribirse y los suscriptores pueden recibir resultados actualizados). Este parece ser...

215
Convertir promesa a observable

Estoy tratando de entender mis observables. Me encanta la forma en que los observables resuelven los problemas de desarrollo y legibilidad. Mientras leo, los beneficios son inmensos. Los observables en HTTP y las colecciones parecen ser sencillos. ¿Cómo puedo convertir algo como esto en un patrón...

192
Observable.of no es una función

Tengo problemas con la Observable.offunción de importación en mi proyecto. Mi Intellij lo ve todo. En mi código tengo: import {Observable} from 'rxjs/Observable'; y en mi código lo uso así: return Observable.of(res); ¿Algunas

182
Crea una suscripción única

Necesito crear una suscripción a una Observableque se elimine de inmediato cuando se llame por primera vez. ¿Hay algo como: observable.subscribeOnce(func); Mi caso de uso, estoy creando una suscripción en un controlador de ruta rápida y la suscripción se llama varias veces por...

167
Devuelve un observable vacío

Se more()supone que la función devuelve una Observablesolicitud get export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ // return empty observable } } private fetch = (): Observable<Response> => {...

153
Operador 'de' vs 'de'

¿Es la única diferencia entre Observable.ofy Observable.fromel formato de los argumentos? ¿Te gusta el Function.prototype.cally Function.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() =>

137
tomar (1) vs primero ()

Encontré algunas implementaciones de AuthGuards que usan take(1). En mi proyecto, solía first(). ¿Ambos funcionan de la misma manera? import 'rxjs/add/operator/map'; import 'rxjs/add/operator/first'; import { Observable } from 'rxjs/Observable'; import { Injectable } from '@angular/core'; import...