Perguntas com a marcação «rxjs»

Qual é a diferença entre Promisee Observableem Angular? Um exemplo em cada um seria útil para entender os dois casos. Em que cenário podemos usar cada

Quando devo armazenar as Subscriptioninstâncias e chamar unsubscribe()durante o ciclo de vida do NgOnDestroy e quando posso simplesmente ignorá-las? Salvar todas as assinaturas introduz muita confusão no código do componente. O Guia do Cliente HTTP ignora assinaturas como esta: getHeroes() {...

Estou analisando os padrões de Angx RxJs e não entendo a diferença entre a BehaviorSubjecte an Observable. Pelo meu entendimento, a BehaviorSubjecté um valor que pode mudar com o tempo (pode ser assinado e os assinantes podem receber resultados atualizados). Esse parece ser exatamente o mesmo...

Estou com um problema com o HTTP no Angular. Eu só quero GETuma JSONlista e mostrá-la na exibição. Classe de serviço import {Injectable} from "angular2/core"; import {Hall} from "./hall"; import {Http} from "angular2/http"; @Injectable() export class HallService { public http:Http; public...

Usando o HTTP, chamamos um método que faz uma chamada de rede e retorna um http observável: getCustomer() { return this.http.get('/someUrl').map(res => res.json()); } Se considerarmos isso observável e adicionar vários assinantes: let network$ = getCustomer(); let subscriber1 =...

Não estou claro sobre a diferença entre a Subjecte a BehaviorSubject. É apenas que a BehaviorSubjecttem a

Estou tentando envolver minha cabeça em observáveis. Adoro a maneira como os observáveis ​​resolvem problemas de desenvolvimento e legibilidade. Enquanto leio, os benefícios são imensos. Observáveis ​​em HTTP e coleções parecem ser diretos. Como posso converter algo assim em padrão...

Você precisa cancelar a inscrição nas chamadas http do Angular 2 para evitar vazamento de memória? fetchFilm(index) { var sub = this._http.get(`http://example.com`) .map(result => result.json()) .map(json => { dispatch(this.receiveFilm(json)); }) .subscribe(e=>sub.unsubscribe());...

Eu tenho um serviço Angular 2: import {Storage} from './storage'; import {Injectable} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; @Injectable() export class SessionStorage extends Storage { private _isLoggedInSource = new Subject<boolean>(); isLoggedIn =...

Acabei de atualizar do Angular 2 beta16 para beta17 , que por sua vez requer o rxjs 5.0.0-beta.6. (Changelog aqui: https://github.com/angular/angular/blob/master/CHANGELOG.md#200-beta17-2016-04-28 ) Na beta16 tudo estava funcionando bem em relação à funcionalidade Observável / mapa. Os seguintes...

Estou tendo problemas com a Observable.offunção de importação no meu projeto. Meu Intellij vê tudo. No meu código eu tenho: import {Observable} from 'rxjs/Observable'; e no meu código eu uso assim: return Observable.of(res); Alguma

Preciso criar uma assinatura para uma Observableque seja imediatamente descartada quando for chamada pela primeira vez. Existe algo como: observable.subscribeOnce(func); No meu caso de uso, estou criando uma assinatura em um manipulador de rota expressa e a assinatura está sendo chamada várias...

Agora, eu tenho uma página inicial onde tenho três links. Depois de clicar no último link de 'amigos', o componente de amigos apropriado é iniciado. Lá, quero buscar / obter uma lista dos meus amigos inseridos no arquivo friends.json. Até agora tudo funciona bem. Mas ainda sou novato no serviço...

A função more()deve retornar um Observablede uma solicitação get export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ // return empty observable } } private fetch = (): Observable<Response> => {...

Código datilografado: import { Injectable } from '@angular/core'; import { Observable } from 'rxjs/Observable'; import { of } from 'rxjs/observable/of'; import { Hero } from './hero'; import { HEROES } from './mock-heroes'; @Injectable({ providedIn: 'root' }) export class HeroService {...

A única diferença entre Observable.ofe Observable.fromo formato dos argumentos? Como o Function.prototype.calle Function.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() =>

Gostaria de fechar meu menu suspenso de login quando o usuário clicar em qualquer lugar fora desse menu suspenso e gostaria de fazer isso com o Angular2 e com a "abordagem" do Angular2 ... Eu implementei uma solução, mas realmente não me sinto confiante com ela. Eu acho que deve haver uma maneira...

Eu recebi um erro de node_modules / rxjs / internal / types.d.ts (81,44): erro TS1005: ';' esperado. após a instalação do Angular 6. Verifique o erro: ERROR in node_modules/rxjs/internal/types.d.ts(81,44): error TS1005: ';' expected. node_modules/rxjs/internal/types.d.ts(81,74): error...

Acho que devo estar entendendo mal algo fundamental, porque, na minha opinião, esse deve ser o caso mais básico para um observável, mas, durante toda a minha vida, não consigo descobrir como fazê-lo a partir dos documentos. Basicamente, eu quero ser capaz de fazer isso: // create a dummy...

Eu encontrei algumas implementações de AuthGuards que usam take(1). No meu projeto, eu usei first(). Os dois funcionam da mesma maneira? import 'rxjs/add/operator/map'; import 'rxjs/add/operator/first'; import { Observable } from 'rxjs/Observable'; import { Injectable } from