Pesquisa de site

javascript - Importar { map } de 'lodash', 'rxjs', 'ramda' ao mesmo tempo sem prejudicar a legibilidade

Como importar map ou merge ou qualquer outra função de múltiplas importações?

import { map } from 'lodash'; import { map } from 'rxjs/operators'; import { map } from 'ramda';

A resposta óbvia é:

import { map

Consulte Mais informação →

javascript - Como implementar um observable quente com expiração de tempo em RxJS (ou de forma geral em Reactive Extensions)

Eu 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

Consulte Mais informação →

javascript - RXJS if com observable como condicional

Eu 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()

Consulte Mais informação →

javascript - Erro: Não é possível encontrar o módulo "rxjs/operators" no Ionic Angular

Estou tentando executar meu projeto Ionic. Estava funcionando bem até alguns dias atrás, agora simplesmente não consigo executá-lo, faça o que eu fizer. Este erro aparece! Tentei remover o Rxjs do package.json e da pasta node_modules, também comentei todos os lugares onde usei Rxjs, ainda assim esse er

Consulte Mais informação →

javascript - RxJS Debounce com prioridade

Estou tendo dificuldade em criar esta transmissão.

O que estou procurando é algo como debounceTime, mas com prioridade.

Então, se eu tiver eventos com o formato { type: 'a', priority: 2 }. Esses eventos precisam ser desacelerados alguns segundos, mas em vez do último evento ser emitido, o evento com a maior prioridade é

Consulte Mais informação →

javascript - RXJS Encadear observáveis dependentes sequencialmente, mas obtendo cada emissão para uma barra de progresso

Estou enfrentando um problema e tenho tentado encontrar uma solução usando RxJs, mas não consigo encontrar uma que se encaixe...

javascript - RxJS: Como posso fazer um "if" com Observables?

Digamos que eu tenha dois observáveis e eu queira escutar as mudanças em um observável, se o outro corresponder a uma certa condição. Eu tentei com zip, mas parece que só serei notificado se ambos os observáveis mudarem, mas eu quero ser notificado para cada mudança em um dos observáveis, se a condição do outr

Consulte Mais informação →

javascript - Contar eventos durante um período de tempo e retornar a soma uma vez por segundo em RxJS

É possível contar eventos ao longo de um período de tempo e gerar a soma a cada segundo no RxJS? Eu tenho um fluxo contínuo de eventos que nunca termina. A cada 1 segundo, eu gostaria de obter o número total de eventos nos últimos 5 minutos. A ideia é usar

Consulte Mais informação →

Como limitar a taxa 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 ele me dá muitos eventos de mousemove. Quero desacelerá-los usando tempo (throttling) ou outro stream de controle. Como posso fazer isso?

Mover o mouse tra

Consulte Mais informação →

typescript - Operadores encadeáveis combinados com RxJS/Angular

É possível (não consigo encontrar nada abrangente sobre isso) combinar múltiplos operadores encadeáveis em uma única função, para que eu possa encadeá-la e reutilizá-la em um método diferente também?

Aqui está a coisa:

public ngOnInit(): void { this.route.url .pipe( swit

Consulte Mais informação →