javascript - Importar { map } de 'lodash', 'rxjs', 'ramda' ao mesmo tempo sem prejudicar a legibilidade
Como se importa map ou merge ou qualquer outra função de múltiplos imports?
import { map } from 'lodash'; import { map } from 'rxjs/operators'; import { map } from 'ramda';A resposta óbvia é:
import { map a Ler mais →javascript - Como implementar um observable quente com expiração de tempo em RxJS (ou de forma geral em Reactive Extensions)
Gostaria de implementar um cache com expiração de tempo usando RxJs. Aqui está um exemplo de cache "normal":
//let this represents "heavy duty job" var data = Rx.Observable.return(Math.random() * 1000).delay(2000); //and we want to cache re Ler mais →javascript - RXJS if com observable como condicional
Quero usar Rx.Observable.if para executar um dos dois observáveis caso um observável condicional resolva para verdadeiro ou falso.
O que eu quero alcançar seria algo assim:
Rx.Observable.if(conditionalObservable.map(x => x.length > 0), firstObservable, secondObservable).subscribe() Ler mais →javascript - Erro: Não é possível encontrar o módulo "rxjs/operators" no Ionic Angular
Estou a tentar executar o meu projeto Ionic. Funcionava bem até há alguns dias, agora simplesmente não consigo executá-lo, faça o que fizer. Este erro aparece! Tentei remover o Rxjs do package.json e da pasta node_modules, também comentei todos os locais onde usei Rxjs, ainda assim este erro aparece. T
Ler mais →javascript - RxJS Debounce com prioridade
Estou com dificuldade em criar este fluxo.
O que estou à procura é algo como debounceTime mas com prioridade.
Então, se eu tiver eventos com o formato { type: 'a', priority: 2 }. Estes eventos precisam ser desacelerados alguns segundos, mas em vez de ser emitido o último evento, é emitido o evento com a maior prioridade
Ler mais →javascript - RXJS Encadear observáveis dependentes sequencialmente, mas obter cada emissão para uma barra de progresso
Estou a enfrentar um problema, e tenho tentado encontrar uma solução usando RxJs, mas não consigo encontrar uma que se adeque...
- Tenho 3 pedidos REST diferentes, que serão chamados sequencialmente, e cada um deles precisa da respos Ler mais →
javascript - RxJS: Como posso fazer um "if" com Observables?
Diz que tenho dois observáveis e quero ouvir alterações num observável, se o outro cumprir uma determinada condição. Tentei com zip, mas parece que só serei notificado se ambos os observáveis mudarem, mas quero ser notificado por cada alteração no observável, se a condição do outro for verdadeira.
O que
Ler mais →javascript - Contar eventos ao longo de um período de tempo e produzir a soma uma vez por segundo em RxJS
É possível contar eventos ao longo de um período de tempo e obter a soma uma vez por segundo em RxJS? Tenho um fluxo contínuo de eventos sem fim. A cada 1 segundo gostaria de obter o número total de eventos nos últimos 5 minutos. A ideia é usar isto para pr
Ler mais →Como limitar a frequência de um evento mousemove em RxJs ao usar Angular 2 + Typescript?
Estou no processo de aprender RxJs. Eu uso Angular2 rc3. O seguinte stream funciona, mas dá-me demasiados eventos de mousemove. Quero abrandá-los usando time (throttling) ou outro stream de controlo. Como é que posso fazer isso?
Mover o rato no
Ler mais →typescript - Operadores encadeáveis combinados com RxJS/Angular
É possível (não consigo encontrar nada abrangente sobre isto) combinar múltiplos operadores encadeáveis numa única função, para que eu possa encadear e reutilizar noutro método também?
Aqui está a coisa:
public ngOnInit(): void { this.route.url .pipe( switchMap( (ids: Ur Ler mais →