Resultados da pesquisa a pedido "rxjs"
O RxJS5 emite itens de matriz ao longo do tempo e repete para sempre
Quero emitir itens de matriz ao longo do tempo (um intervalo de um segundo entre cada emissão) e quando todos os itens tiverem sido emitidos, repita várias vezes. Eu sei como fazer isso, mas quero saber se há algo mais sucinto do que .. const ...
Observable.forkJoin () não executa
Eu tenho o seguinte código: //Loop: For each user ID/Role ID, get the data userMeta.forEach((businessRole) => { Observable.forkJoin( af.database.object('/roles/'+businessRole.$value), af.database.object('/users/'+businessRole.$key) ).subscribe( ...
O SystemJS carrega muitos arquivos para rxjs
Eu tenho o seguintesystemjs.config.js (com base em algum exemplo que encontrei na internet): (function (global) { System.config({ paths: { // paths serve as alias 'js:': 'js/', }, // map tells the System loader where to look for things map: { // ...
ForquilhaJoin 2 Comportamento
Eu tenho dois fluxos de assuntos de comportamento que estou tentando forçar a entrar sem sorte. Como imaginei, ele devolve os dois últimos valores. É possível implementá-lo de alguma forma? Não é chamado após o assunto. let stream1 = new ...
Forquilha observável
Estou tentando usarforkJoin em dois observáveis. Um deles começa como um fluxo ... Se eu os assino diretamente, recebo uma resposta,forkJoin não está disparando embora. Alguma ideia? private data$: Observable<any[]>; private statuses$: ...
Melhor maneira de importar o Observable de rxjs
No meu aplicativo angular 2, tenho um serviço que usa oObservable classe dorxjs biblioteca. import { Observable } from 'rxjs';No momento estou apenas usandoObservable para que eu possa usar otoPromise() função. Eu li em outra pergunta ...
Combine operadores RxJS em um novo operador usando o TypeScript
Frequentemente, eu mesmo adiciono a mesma sequência de operadores aos observáveis, por exemplo observable$ .do(x => console.log('some text', x)) .publishReplay() .refCount(); Estou procurando uma maneira de combinar esses três operadores em um ...
Acionando o comportamento global para um componente de "carregamento", como com a emissão $ de Angular 1
Estou criando um componente de sobreposição de carregamento no Angular 2 e percebi que não tenho certeza de como ativá-lo. No Angular 1, eu emitia algo e ouvia na diretiva de carregamento giratório, para ocultar ou mostrar. No Angular 2, suspeito ...
O assinante não recebe valor de .next ()
Estou tentando criar um serviço compartilhado para se comunicar entre componentes usando um Observable, ...
Rxjs 5 - Solicitação simples de Ajax
Estou tentando obter o valor de uma simples solicitação de ajax, mas não entendo como fazer isso. Aqui está o código: Rx.Observable .ajax({ url: 'https://jsonplaceholder.typicode.com/posts', method: 'GET', responseType: 'json' }) ...