angular - Devolver el resultado de un observable con combineLatest y Rxjs

Deseo obtener el resultado de un observable que reste el valor por defecto cada vez que el valor cambie

Cada vez que el valor cambia, se resta el valor predeterminado por el nuevo valor ingresado en el campo de entrada

Por ejemplo, el valor predeterminado es 5.

Ingreso 4 en el c

Leer más →

angular - ¿Cómo acceder a Rx.Scheduler.immediate a través de rxjs usando SystemJS/Angular2?

Me gustaría usar el ImmediateScheduler de RxJS en mi proyecto de Angular2.

Sin embargo, en mi instalación de RxJS, esto no existe. Estoy usando "rxjs": "5.0.0-beta.12" en mi package.json, que es requerido por Angular 2.1.2.
Al mirar en la carpeta node_modules/ encuentro una carpeta 'rxjs' y una carpeta 'rx'. El ImmediateScheduler no es parte de 'rxjs', sino de 'rx'. Puedo encontrarlo allí en 'rx/dist/rx.lite.js' o incluso en 'rx/ts/rx/rx-lite.ts' como TypeScript, que es lo que estoy

Leer más →

typescript - Rxjs: forma abreviada de crear un observable a partir de un valor u observable

Estoy usando rxjs con TypeScript. Escribí las siguientes dos funciones simples. Pero supongo que rxjs ya tiene esa funcionalidad. ¿Lo tiene rxjs?

export function isObservable(value: any): value is Observable<any> { return value inst

Leer más →

typescript - Firebase y RxJS

Hice una función que escucha eventos de valor:

getUnreadMessages() : Observable<any>{ return new Observable(observer =>{ firebase.database().ref('messages/' + this.userService.getUserID()).on("value", (snapshot : any) =>{ let count = 0; ...some more logic here... observer.next(count); observer.complete(); }, (error) =>{ observer.error(error); }) }) }

Cuando la base de datos camb

Leer más →

angular - los operadores de RXJS no funcionan con firebase

Estoy usando los operadores de RXJS con el observable de Firebase (distinct y filter). este es mi árbol de Firebase aquí. este es mi código:

let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ conso

Leer más →

javascript - Typescript resolviendo módulos de 'rxjs' de manera diferente en el mismo archivo

He pasado horas dando vueltas en círculos, así que es hora de otra pregunta oscura.

Estoy dentro de un mono repositorio lerna, con dos subproyectos, ProjectA y ProjectB.

ProjectA tiene una dependencia de rxjs, al i

Leer más →

TypeScript - RxJS6: reiniciar flujo después de la finalización

He estado jugando un poco con RxJS 6. Estoy tratando de implementar dragstart, dragmove y dragend. Este es el código que tengo hasta ahora.

import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { ta

Leer más →

typescript - Con RxJs en Angular, ¿necesito completar únicamente los Observables creados en el componente?

Básicamente, todavía no estoy muy seguro sobre la limpieza del código reactivo en los componentes de Angular. ¿Son correctas y suficientes las siguientes reglas?

Mis reglas para un componente reactivo:

• en manual x.subscribe():

  • si se usa x.takeUntil(...) o un constructo similar entonces no hay limpieza manual
  • si x.complete() se llama en el ámbito del componente, entonces no hay limpieza manual
  • de lo contrario, manua
    Leer más →

typescript - paginación de rxjs con suscripción a cada página

Estamos consultando graphql a través de websocket para tener una suscripción a una lista de entidades. Usamos paginación ya que se supone que la lista se puede desplazar indefinidamente. También queremos ver los cambios realizados en la base de datos en tiempo real en la lista en el front-end.

Esta lista puede ser filtrada, ordenada y paginada.

Tenemos la clase SelectParams que nos ayuda a hacer eso:

ex

Leer más →

typescript - Angular 6 Error al usar RxJS: No se puede leer la propiedad 'call' de indefinido

Estoy intentando migrar una aplicación de Angular 5 a Angular 6 y tengo este bloque de código de RxJS que me tiene desconcertado. He buscado en Google y leído los documentos de RxJS lo suficiente como para saber que debería estar usando .pipe, pero no logro entender del todo la sint

Leer más →