Resultados da pesquisa a pedido "rxjs"
forkjoin observável angular2 rxjs
É possível continuar entrando com solicitações http.get mesmo se uma delas falhar. Estou procurando uma função semelhante de $ q.allSettled em angular2. Consultar exemplo ...
RXJS Observable doSomething onComplete
Eu gostaria de usar o RXJS Observable. Basicamente, funciona bem, mas não preciso apenas reagir quandoobserver.next () mas também quandoobserver.complete () é chamado. Como obtenho o evento OnComplete de um Observável RXJS? Na minha opinião, o ...
Como pode um mock um http observável no Angular2 para quando nenhuma API é escrita
Eu sou novo no Angular2 e no Rxjs e estou um pouco confuso sobre um caso específico. Eu tenho um serviço simples: import { Injectable } from '@angular/core'; import { Observable, Subject } from 'rxjs/Rx'; import { Http, Response } from ...
Aguarde outro observável antes de continuar
Não sei se devo postar algum código para isso. Mas eu vou, se necessário. Eu tenho uma diretiva Angular2,MyDirective e um serviçoMyService O serviço faz uma chamada http em seu construtor para buscar algo e armazenar, por ...
Os RxJs capturam erros e continuam
Eu tenho uma lista de itens para analisar, mas a análise de um deles pode falhar. O que é o "Rx-Way" para detectar erros, mas continua executando a sequência Exemplo de código: var observable = Rx.Observable.from([0,1,2,3,4,5]) .map( ...
A propriedade 'toPromise' não existe no tipo 'Observable <Response>'
import { Headers, Http } from '@angular/http'; @Injectable() export class PublisherService{ private publishersUrl = 'app/publisher'; constructor(private http: Http) { } getPublishers(): Promise<Publisher[]>{ ...
Como vincular bidirecionalmente meu próprio RxJS Subject a um [(ngModel)]?
Existe uma maneira curta e simples de passar um RxJSSubject [http://reactivex.io/rxjs/class/es6/Subject.js~Subject.html]ouBehaviorSubject [http://reactivex.io/rxjs/class/es6/BehaviorSubject.js~BehaviorSubject.html]a uma diretiva Angular 2 para ...
FirebaseListObservable torna-se Observable após consulta
Eu fiz um pequeno aplicativo no firebase. Eu tenho usado um tipo fornecido pelo angularfire chamado FirebaseListObservable que permite observar alterações nos seus dados. O problema que estou tendo é que o Angularfire também fornece uma maneira ...
Angular 2 Http, Observables e solicitações recursivas
Eu tenho um ponto de extremidade REST que retorna uma lista de itens, no máximo 1000 itens por vez. Se houver mais de 1000 itens, a resposta terá o status HTTP 206 e haverá umaNext-Range cabeçalho que posso usar na minha próxima solicitação para ...
RxJs Observables: execute retryWhen depois de mais algumas solicitações assíncronas
Meu caso de uso é: O usuário solicita ativos de nossa API que falham devido à expiração do JWT (transmitido como um cookie httpOnly) - a API retorna um código de status 401.Nós os autenticamos (sem que o usuário faça nada) novamente usando ...