Pesquisa de site
angular - Retornar resultado de um observable com combineLatest e Rxjs
Eu 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 inserido no campo de entrada
Por exemplo, o valor padrão é 5.
Eu insiro 4 no campo de entrada
O resultado
Consulte Mais informação →angular - Como acessar Rx.Scheduler.immediate através do rxjs usando SystemJS/Angular2?
Eu gostaria de usar o ImmediateScheduler do RxJS no meu projeto Angular2.
No entanto, na minha instalação do RxJS, isso não existe. Estou usando "rxjs": "5.0.0-beta.12" no meu package.json, que é exigido pelo Angular 2.1.2.
Ao olhar na pasta node_modules/, encontrei uma pasta 'rxjs' e uma pasta 'rx'. O ImmediateScheduler não faz parte do 'rxjs', mas do 'rx'. Posso encontrá-lo lá em 'rx/dist/rx.lite.js' ou até mesmo em 'rx/ts/rx/rx-lite.ts' como TypeScript, que estou usando.
Te
Consulte Mais informação →typescript - Rxjs: forma abreviada de criar observable a partir de um valor ou observable
Estou usando rxjs com TypeScript. Escrevi as seguintes duas funções simples. Mas acho que o rxjs já possui essa funcionalidade. O rxjs possui?
export function isObservable(value: any): value is Observable<any> { return value instanc Consulte Mais informação →typescript - Firebase e RxJS
Eu fiz 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 o banco de dados muda
Consulte Mais informação →angular - operadores RXJS não funcionando com firebase
Estou usando os operadores RXJS com o observable 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 Consulte Mais informação →javascript - Módulo Typescript resolvendo 'rxjs' de maneira diferente no mesmo arquivo
Passei horas andando em círculos, então é 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, assim como
Consulte Mais informação →typescript - RxJS6: reiniciar stream após a conclusão
Tenho brincado um pouco com RxJS 6. Estou tentando 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 { takeUntil } Consulte Mais informação →typescript - Com RxJs no Angular, eu preciso apenas completar os Observables criados no componente?
Basicamente, ainda não tenho muita certeza sobre a limpeza de código reativo em componentes Angular. As seguintes regras estão corretas e são suficientes?
Minhas regras para um componente reativo:
no manual x.subscribe():
- se estiver usando x.takeUntil(...) ou construção similar, então não é necessário limpar manualmente
- se x.complete() for chamado no escopo do componente, então não há limpeza manual
- ou manualmente Consulte Mais informação →
typescript - paginação rxjs com assinatura para cada página
Estamos consultando graphql via websocket para ter uma assinatura de uma lista de entidades. Usamos paginação, pois a lista é suposta ser rolável indefinidamente. Também queremos ver mudanças feitas no banco de dados em tempo real 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 { page = 0; Consulte Mais informação →typescript - Angular 6 Erro usando RxJS: Não é possível ler a propriedade 'call' de indefinido
Estou tentando migrar um aplicativo Angular 5 para Angular 6 e tenho este bloco de código RxJS que me deixou perplexo. Eu pesquisei no Google e li a documentação do RxJS o suficiente para saber que devo usar .pipe, mas não consigo entender bem a sintaxe.
O código retorna resul
Consulte Mais informação →