Resultados da pesquisa a pedido "rxjs"
Angular 2 + rxjs - como retornar o fluxo de objetos buscados com várias solicitações http subsequentes
Eu tenho classes de dados class Processor { frequency: number; error: booelan; } class Computer { name: string; processor: Processor[]; }Eu o retiro do back-end usando json: { "name": "Alfa Beta", "processors": [ { "url": "ASD3-455R-FRTT-ASEW" ...
Como retornar observável da assinatura
Estou tentando retornar um observável quando recebo um determinado valor em um assinante, mas falho miseravelmente. Este é o código: canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot):Observable<boolean> { // get route to be ...
Rxjs - consome a saída da API e consulta novamente quando o cache está vazio
Estou tentando implementar uma versão doesta introdução ao RxJS [https://xgrommx.github.io/rx-book/content/guidelines/introduction/index.html] ( mexer aqui [http://jsfiddle.net/staltz/8jFJH/48/]) que, em vez de escolher um objeto aleatório de uma ...
Mesclar sub-matrizes usando Observables
Eu tenho essa estrutura de dados: [{ id : 1, name : "Item 1", subItems : [{ id : 1, name : "SubItem 1" },{ id : 2, name : "SubItem 2" } ] }, { id : 2, name : "Item 2", subItems : [{ id : 3, name : "SubItem 3" }, { id : 4, name : "SubItem 4" } ] ...
RxJS - .subscribe () vs .publish (). Connect ()
Esta é principalmente uma questão de melhor prática / abordagem do RxJs, pois meu código POC funciona, mas eu sou novo no RxJs. A questão se resume a.subscribe() vs.publish().connect(), pois os dois parecem fazer a mesma coisa. No meu ...
obtenha um novo ticket e tente novamente o primeiro pedido
Atualizar:Eu estendo a classe Http, quando eudeleteDocument() Eu quero lidar com erro entãogetTicket() tente novamente ma requestdeleteDocument() com novothis.TICKET : @Injectable() export class HttpService extends Http { public SERVER_URL: ...
Instrução de mapa aninhado RxJS Refactor
Eu tenho um serviço que usa@angular/http para carregar dados de uma API. Quero criar uma projeção dos dados recuperados para o meuComponents usando esses dados. Portanto, eu escrevi o seguinte código: getById(id: string) { return this.http ...
angular2 / RxJS - como tentar novamente de dentro de subscribe ()
este é o meu código: this._api.getCompanies().subscribe( res => this.companies = JSON.parse(res), exception => {if(this._api.responseErrorProcess(exception)) { // in case this retured TRUE then I need to retry() } } )caso ocorra uma exceção, ela ...
Como usar retryWhen com uma função que retorna um booleano?
Aqui está o meu código: this._http.post(this._url_get + extension, '', { headers: headers }) .map(res => res['_body']) .retryWhen(errors => {return responseErrorProcess(errors)})agora eu preciso pegar exceções e passá-las para o ...
Atualize várias propriedades do componente com uma única chamada http usando observáveis
Post anterior relacionado: Angular2: reduza o número de chamadas HTTP [https://stackoverflow.com/questions/39345083/angular2-reduce-number-of-http-calls/39348998#39348998] O contexto ainda é o mesmo: estou tentando configurar um componente ...