Resultados da pesquisa a pedido "rxjs"
Rxjs observando atualizações e alterações de objetos
Atualmente, estou tentando observar alterações em um determinado objeto, incluindo todos os seus elementos. O código a seguir é acionado somente quando um objeto [x] é atualizado, mas não se você atualiza individualmente os elementos do objeto ...
Criando um canal de comunicação entre componentes no Angular
Então, eu tenho dois componentes, CompA e compA5, com 3 ou 4 níveis de diferença. Quero criar um canal de comunicação entre os componentes. Digamos que do componente CompA eu quero enviar um evento para o compA5 para retornar alguns dados, ...
Transforme várias solicitações de ajax em Observables com o RxJS
Estou lutando com algo - o que acho que significa que eu entendi mal e estou fazendo algo bobo Eu tenho um observável e preciso usá-lo para criar algum objeto, enviá-lo ao servidor para processamento, combinar um resultado do servidor com o ...
RxJS: Como eu "manualmente" atualizava um Observable?
Acho que devo estar entendendo mal algo fundamental, porque, na minha opinião, esse deve ser o caso mais básico para um observável, mas, durante toda a vida, não consigo descobrir como fazê-lo a partir dos documentos. Basicamente, eu quero ser ...
Como carregar o RxJS em um aplicativo Angular 2 mínimo usando systemjs?
Não consigo obter um aplicativo Angular 2 mínimo usando RxJS do zero. Estou usando o Typescript (tsc 1.6.2) e systemjs para carregamento do módulo. Como faço para o systemjs carregar o módulo Rx corretamente? Eu fiquei sem idéias para tentar e ...
Como criar um buffer RxJS que agrupa elementos no NodeJS, mas que não depende de um intervalo de execução permanente?
Estou capturando eventos de um aplicativo usandoRx.Observable.fromEvent em um NodeJS. Eles são enviados para outro servidor usando request ( https://www.npmjs.com/package/request [https://www.npmjs.com/package/request]) Para evitar uma carga de ...
Por que precisamos usar o flatMap?
Estou começando a usar o RxJS e não entendo por que, neste exemplo, precisamos usar uma função comoflatMap ouconcatAll; Onde está a matriz de matrizes aqui? var requestStream = Rx.Observable.just('https://api.github.com/users'); ...
Como iniciar o segundo observável * somente * depois que o primeiro é * completamente * feito em rxjs
Eu estava com a impressão de queObservable.[prototype.]concat garante que a primeira operação esteja totalmente concluída antes do início da segunda operação. Mas no seguinte código: Observable ...
O rxjs observable não é concluído quando ocorre um erro
Quando crio um observável a partir do zero e o erro do observador é concluído, a parte concluída da assinatura nunca é chamada. var observer = Rx.Observable.create(function(observer){ observer.onError(new Error('no!')); observer.onCompleted(); ...
Como solicitar dados sequencialmente no Cycle.js?
Eu sou novo na programação reativa e brinco com o cycle.js, tentando implementar a caixa a seguireste tutorial [https://gist.github.com/staltz/868e7e9bc2a7b8c1f754]. Mas entendi que, para a implementação adequada (e para fins de aprendizado), não ...