Resultados da pesquisa a pedido "rxjs5"
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: { // ...
Forquilha une dois observáveis do firebase
Eu estou usando angular2fire. Estou consultando e tentando obter todos os passeios de uma cidade. getAllTours(cityId) { return this.af.database.list(`/cities/${cityId}/tours`) .map((tours): any => { tours.map((tour: any) => { tour.tour ...
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$: ...
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 ...
Função "Cancelar inscrição" retorno de chamada / gancho na função Observador "executor"
Estou confuso sobre qual é o objetivo da função "descartar" ou "cancelar a assinatura", que é (opcionalmente) retornada de uma função observável de "executor", assim: const Rx = require('rxjs'); const obs = Rx.Observable.create(obs => { // we ...
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' }) ...
Como lidar com vários tipos de ação em um épico? Quaisquer contras de fazer o mesmo?
Muito novo para redux-observables, rxjs e observables. Queria saber como lidar com outra ação, diga 'ActionTwo' no mesmo épico const Epic1 = (action$,store) => { return action$.ofType('ActionOne') .mergeMap((action) => { return ajax({'method': ...
Inscrever-se para vários Observáveis em Angular 2
Meu aplicativo Angular 2 possui 2 métodos [GetCategories () e GetCartItems ()] em um serviço, e esses dois métodos retornam Observables. Para invocar esses dois métodos um após o outro do meu componente, escrevi o código abaixo ngOnInit() { ...
Rx.Subject é um observável quente?
O código const a = new Rx.Subject().do(x => console.log('a')) const b = a.mapTo(0) const c = a.mapTo(1) const d = Rx.Observable.merge(b, c) d.subscribe(x => console.log('d')) a.next(3)E a saída a d a dPor que uma impressão foi impressa duas ...