Resultados da pesquisa a pedido "rxjs"
Promise.all comportamento com RxJS Observables?
No Angular 1.x, às vezes eu precisaria fazer váriashttp solicita e faz algo com todas as respostas. Eu jogaria todas as promessas em uma matriz e chamariaPromise.all(promises).then(function (results) {...}). As melhores práticas do Angular 2 ...
Como posso fechar uma lista suspensa ao clicar fora?
Gostaria de fechar meu menu suspenso de login quando o usuário clicar em qualquer lugar fora desse menu suspenso e gostaria de fazer isso com o Angular2 e com a "abordagem" do Angular2 ... Eu implementei uma solução, mas realmente não me sinto ...
RXJS: debounce agregado
Meu caso de uso é o seguinte: Recebo eventos, que às vezes acontecem em rajadas. Se ocorrer uma explosão, eu só preciso lidar com isso uma vez. Debounce faz isso. No entanto, o debounce apenas me fornece o último elemento de uma explosão, ...
Rx: um operador zip que continua depois que um dos fluxos termina?
Estou procurando combinar fluxos (observáveis) que iniciam e terminam de forma assíncrona: -1----1----1----1---|-> -2----2--|-> [ optional_zip(sum) ] -1----3----3----1---|->Para o que eu preciso: Adicionando fluxos de áudio juntos. Eles são ...
RxJs: exemplo de arrastar e soltar: adicionar mousedragstart
Como implementar ummousedragstart Observável usando oArraste e solte o exemplo de RxJs [https://github.com/Reactive-Extensions/RxJS/blob/master/examples/dragndrop/dragndrop.js] . mousedragstart deve ser emitido antes do primeiromousedrag após ...
Como saber quando todas as chamadas HTTP Angular2 são concluídas
Estou escrevendo um aplicativo que monitora o número de compilação atual de todos os nossos aplicativos em diferentes servidores. Isso é feito fazendo uma solicitação http para um arquivo txt em todos os aplicativos. Estou fazendo isso usando um ...
RxJs: pesquisa até o intervalo terminar ou corrigir dados recebidos
Como executo o seguinte cenário no navegador com RxJs: enviar dados para a fila para processamentovoltar a identificação do trabalhosondar outro ponto de extremidade a cada 1s até que o resultado esteja disponível ou 60 segundos após (depois ...
Existe uma maneira de criar essa sequência de Streams?
Estou tentando implementar esse diagrama de mármore, com a hipotesis de ter um número N de sN $, e estou adicionando esses fluxos ao $ principal. s1$ +--1--------------------99---------------------> ...
Como gerenciar estado sem usar Assunto ou manipulação imperativa em um exemplo simples de RxJS?
Estou experimentando o RxJS há duas semanas e, embora eu o ame em princípio, não consigo encontrar e implementar o padrão correto para gerenciar o estado. Todos os artigos e perguntas parecem concordar: Subject sempre que possível, deve ser ...
Angular 2 retornam dados de RxJs
Eu tenho um serviço com uma função de autenticação - authenticate(username: string, password: string) { let ret; let packet = JSON.stringify({ username: username, password: password }); let headers = new Headers(); headers.append('Content-Type', ...