Na página de documentação do Angular 2 para usar o serviço Http, há um exemplo. getHeroes (): Observable<Stuff[]> { return this.http.get(this.url) .map(this.extractData) .catch(this.handleError); } Clonei o projeto angular2-webpack-starter e adicionei o código acima. Eu importei...
Tenho procurado entender esses 3: Assunto , assunto de comportamento e assunto de repetição . Eu gostaria de usá-los e saber quando e por que, quais são os benefícios de usá-los e embora tenha lido a documentação, assistido tutoriais e pesquisado no google, não consegui entender isso. Então,...
Estou tendo um serviço que tem este método: export class TestModelService { public testModel: TestModel; constructor( @Inject(Http) public http: Http) { } public fetchModel(uuid: string = undefined): Observable<string> { if(!uuid) { //return Observable of JSON.stringify(new...
Eu sei que Redux é uma "implementação" melhor do Flux, ou melhor dizendo, é um redesenho para simplificar as coisas (gerenciamento de estado do aplicativo). Já ouvi muito sobre programação reativa (RxJS), mas ainda não mergulhei para aprender. Então, minha pergunta é: há alguma interseção (algo...
Alguém pode dar uma definição clara junto com um exemplo simples que explica o que é um "inferno de callback" para alguém que não conhece JavaScript e node.js? Quando (em que tipo de configurações) ocorre o "problema de retorno de chamada"? Por que isso ocorre? O "inferno de retorno de chamada"...
Pipes são filtros para transformar dados (formatos) no modelo. Me deparei com a pipe()função abaixo. O que essa pipe()função significa exatamente neste caso? return this.http.get<Hero>(url) .pipe( tap(_ => this.log(`fetched hero id=${id}`)),
Eu gostaria de ser capaz de esperar em um observável, por exemplo const source = Rx.Observable.create(/* ... */) //... await source; Uma tentativa ingênua resulta em esperar resolvendo imediatamente e não bloqueando a execução Editar: o pseudocódigo para meu caso de uso pretendido completo...
De acordo com este artcle , onCompletee onErrorfunção do subscribesão mutuamente exclusivas. Ou seja, os eventos onErrorou onCompletevão disparar no meu subscribe. Eu tenho um bloco lógico que precisa ser executado se eu receber um erro ou terminar meu fluxo de informações com sucesso....
Em uma aplicação angular, temos um ngOnDestroy()gancho de ciclo de vida para um componente / diretiva e usamos esse gancho para cancelar a assinatura dos observáveis. Quero limpar / destruir observáveis que são criados em um @injectable()serviço. Eu vi alguns posts dizendo quengOnDestroy() pode...
Quando executo o linter, ele diz: subscribe is deprecated: Use an observer instead of an error callback Código (de um app angular 7 com angular-cli): this.userService.updateUser(data).pipe( tap(() => {bla bla bla}) ).subscribe( this.handleUpdateResponse.bind(this),
Não sei como extrair valor de Observable para ser retornado pela função em que Observable está presente. Preciso apenas de um valor para ser devolvido, nada mais. Versão atual que funciona function getValueFromObservable() { this.store.subscribe( (data:any) => { console.log(data) }...
Atualmente, estou tentando aprender Angular2 e TypeScript depois de trabalhar com prazer com AngularJS 1. * nos últimos 4 anos! Tenho que admitir que estou odiando isso, mas tenho certeza de que meu momento eureka está chegando ... de qualquer maneira, escrevi um serviço em meu aplicativo fictício...
Digamos que tenho um Observable, assim: var one = someObservable.take(1); one.subscribe(function(){ /* do something */ }); Então, eu tenho um segundo Observable: var two = someOtherObservable.take(1); Agora, eu quero subscribe()a two, mas eu quero ter certeza de que onetenha concluído...
Quero lançar um erro do operador de mapa do meu observável com base em uma condição. Por exemplo, se os dados API corretos não forem recebidos. Por favor, veja o seguinte código: private userAuthenticate( email: string, password: string ) { return
Estou começando a usar o RxJS e não entendo porque neste exemplo precisamos usar uma função como flatMapou concatAll; onde está a matriz de matrizes aqui? var requestStream = Rx.Observable.just('https://api.github.com/users'); var responseMetastream = requestStream
Estou tentando entender como usar Observáveis no Angular 2. Tenho este serviço: import {Injectable, EventEmitter, ViewChild} from '@angular/core'; import {Observable} from "rxjs/Observable"; import {Subject} from "rxjs/Subject"; import {BehaviorSubject} from "rxjs/Rx"; import...
Extraí um código de modelo de amostra deste tutorial e executei as duas etapas abaixo para começar - npm install // worked fine and created node_modules folder with all dependencies npm start // falhou com o erro abaixo- node_modules/rxjs/Subject.d.ts(16,22): error TS2415: Class...
No Angular 1.x, às vezes eu precisava fazer várias httpsolicitações e fazer algo com todas as respostas. Eu jogaria todas as promessas em uma série e ligaria Promise.all(promises).then(function (results) {...}). As melhores práticas do Angular 2 parecem apontar para o uso de RxJS Observablecomo...
Na semana passada, respondi a uma pergunta do RxJS em que entrei em uma discussão com outro membro da comunidade sobre: "Devo criar uma assinatura para cada efeito colateral específico ou devo tentar minimizar as assinaturas em geral?" Quero saber qual metodologia usar em termos de uma abordagem...
Eu tenho um componente, que "carrega preguiçosamente" alguns comentários, no intervalo de 100ms. Quando eu uso o setTimeout, é realmente lento. componente <div *ngFor="let post of posts"> <app-post [post]="post" ></app-post> </div> Isso torna meu aplicativo lento...