Articles of rxjs

Por que precisamos usar o flatMap?

Estou começando a usar o RxJS e não entendo porque neste exemplo precisamos usar uma function como flatMap ou concatAll ; onde está a matriz de matrizes aqui? var requestStream = Rx.Observable.just(‘https://api.github.com/users’); var responseMetastream = requestStream .flatMap(function(requestUrl) { return Rx.Observable.fromPromise(jQuery.getJSON(requestUrl)); }); responseMetastream.subscribe(url => {console.log(url)}) Se alguém puder explicar visualmente o que está acontecendo, será muito […]

Quais são as semânticas de diferentes sujeitos RxJS?

A documentação para o tópico é esparsa e é difícil descobrir um “ponto de input” lá.

Qual é a diferença entre Subject and BehaviorSubject?

Não estou claro sobre a diferença entre um assunto e um BehaviorSubject. É só que um BehaviorSubject tem a function getValue?

É necessário cancelar a assinatura dos observáveis ​​criados pelos methods Http?

Você precisa cancelar a assinatura das chamadas http Angular 2 para evitar memory leaks? fetchFilm(index) { var sub = this._http.get(`http://example.com`) .map(result => result.json()) .map(json => { dispatch(this.receiveFilm(json)); }) .subscribe(e=>sub.unsubscribe()); …

Erro de tipo observável: não é possível ler a propriedade de undefined

Angular 2 aplicação, eu recebo um erro: não é possível ler a propriedade ‘título’ de indefinido. Este é um componente muito simples, apenas tentando obter um mínimo para trabalhar aqui. Ele atingiu o meu controlador de API (curiosamente várias vezes), e parece atingir a área no meu código que é o retorno de chamada depois […]

Observables quentes e frios: há operadores ‘quentes’ e ‘frios’?

Eu revisei a seguinte questão SO: Quais são os observáveis ​​Hot e Cold? Para resumir: um frio observável emite seus valores quando tem um observador para consumi-los, ou seja, a sequência de valores recebidos pelos observadores é independente do tempo de assinatura. Todos os observadores irão consumir a mesma sequência de valores. um hot observable […]

BehaviorSubject vs Observable?

Eu estou olhando para padrões Angular RxJs e não entendo a diferença entre um BehaviorSubject e um Observable . Pelo que entendi, um BehaviorSubject é um valor que pode mudar com o tempo (pode ser assinado e os assinantes podem receber resultados atualizados). Este parece ser exatamente o mesmo propósito de um Observable . Quando […]

Promessa vs Observável

Alguém pode explicar a diferença entre Promise e Observable in Angular? Um exemplo sobre cada um deles seria útil para entender os dois casos. Em que cenário podemos usar cada caso?

HTTP angular GET com erro de TypeScript http.get (…) .map não é uma function em

Eu tenho um problema com o HTTP em Angular. Eu só quero obter uma lista JSON e mostrá-lo na visã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 static PATH:string = ‘app/backend/’ constructor(http:Http) { this.http=http; } getHalls() { return this.http.get(HallService.PATH […]

Angular / RxJs Quando devo cancelar a assinatura do `Subscription`

Quando devo armazenar as instâncias da Subscription e invocar unsubscribe() durante o ciclo de vida do NgOnDestroy e quando posso simplesmente ignorá-las? Salvar todas as inscrições introduz muita confusão no código do componente. Guia do Cliente HTTP ignora assinaturas como esta: getHeroes() { this.heroService.getHeroes() .subscribe( heroes => this.heroes = heroes, error => this.errorMessage = error); […]