angular - Retornar resultado de um observable com combineLatest e Rxjs
Desejo obter o resultado de um observável que subtrai o valor padrão cada vez que o valor muda
Cada vez que o valor muda, ele subtrai o valor padrão pelo novo valor introduzido no campo de entrada
Por exemplo, o valor predefinido é 5.
Eu insiro 4 no campo de entrada
O resu
Ler mais →angular - Como aceder a Rx.Scheduler.immediate através do rxjs usando SystemJS/Angular2?
Gostaria de usar o ImmediateScheduler do RxJS no meu projeto Angular2.
No entanto, na minha instalação do RxJS, isto não existe. Estou a usar "rxjs": "5.0.0-beta.12" no meu package.json, o qual é exigido pelo Angular 2.1.2.
Ao verificar na pasta node_modules/, encontro uma pasta 'rxjs' e uma pasta 'rx'. O ImmediateScheduler não faz parte do 'rxjs', mas sim do 'rx'. Posso encontrá-lo aí em 'rx/dist/rx.lite.js' ou mesmo em 'rx/ts/rx/rx-lite.ts' como TypeScript, que é o que estou a usa
typescript - Rxjs: forma abreviada de criar um observable a partir de um valor ou observable
Estou a usar rxjs com TypeScript. Escrevi as seguintes duas funções simples. Mas penso que o rxjs já tem essa funcionalidade. O rxjs tem?
export function isObservable(value: any): value is Observable<any> { return value instanceof O Ler mais →typescript - Firebase e RxJS
Eu criei uma função que escuta 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); }) }) }Quando a base de dados mud
Ler mais →angular - operadores RXJS não funcionam com firebase
Estou a usar os operadores RXJS com o observável do Firebase (distinct e filter). esta é a minha árvore do Firebase aqui. este é o meu código:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ con Ler mais →javascript - Módulo Typescript a resolver 'rxjs' de forma diferente no mesmo ficheiro
Passei horas a andar em círculos, por isso é hora de outra pergunta obscura.
Estou dentro de um mono repositório lerna, com dois subprojetos, ProjectA e ProjectB.
ProjectA tem uma dependência de rxjs, tal como
Ler mais →typescript - RxJS6: reiniciar stream após a conclusão
Tenho estado a brincar um pouco com o RxJS 6. Estou a tentar implementar dragstart, dragmove e dragend. Este é o código que tenho até agora.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { t Ler mais →typescript - Com RxJs no Angular, preciso apenas completar os Observables criados no componente?
Basicamente, ainda não tenho muita certeza sobre a limpeza do código reativo em componentes Angular. As seguintes regras estão corretas e são suficientes?
As minhas regras para um componente reativo:
no manual x.subscribe():
- se estiver a usar x.takeUntil(...) ou uma construção semelhante, então não é necessário fazer limpeza manual
- se x.complete() for chamado no âmbito do componente, então não é necessária qualquer limpeza Ler mais →
typescript - paginação rxjs com subscrição a cada página
Estamos a consultar graphql através de websocket para ter uma subscrição de uma lista de entidades. Usamos paginação visto que a lista se supõe ser rolável indefinidamente. Também queremos ver em tempo real as alterações feitas na base de dados na lista no front-end.
Esta lista pode ser filtrada, ordenada e paginada.
Temos a classe SelectParams que nos ajuda a fazer isso:
export class SelectParams { Ler mais →typescript - Angular 6 Erro ao usar RxJS: Não é possível ler a propriedade 'call' de indefinido
Estou a tentar migrar uma aplicação Angular 5 para Angular 6 e tenho este bloco de código RxJS que me deixa perplexo. Pesquisei no Google e li a documentação do RxJS o suficiente para saber que devo usar .pipe, mas não consigo perceber bem a sintaxe.
O código retorna resultado
Ler mais →