Articles of rxjs

Como fazer a sequência da cadeia em rxjs

Eu gostaria de algo como: this._myService.doSomething().subscribe(result => { doSomething() }); .then( () => dosthelse() ) .then( () => dosanotherthing() ) Então, eu gostaria de acorrentar. Então, como na promise. Como eu faria isso em Rxjs? this._myService.getLoginScreen().subscribe( result => { window.location.href = MyService.LOGIN_URL; /// I would like to wait for the site to load and alert […]

Composição de Promessa RxJS (passando dados)

Eu sou novo em Rx e estou achando difícil encontrar documentação sobre a composição de promises, de modo que os dados da primeira promise sejam passados ​​para a segunda e assim por diante. Aqui estão três promises básicas, os cálculos nos dados não são importantes, apenas que algo asynchronous deve ser feito usando dados da […]

Como obter o valor atual do Assunto RxJS ou Observável?

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(); isLoggedIn = this._isLoggedInSource.asObservable(); constructor() { super(‘session’); } setIsLoggedIn(value: boolean) { this.setItem(‘_isLoggedIn’, value, () => { this._isLoggedInSource.next(value); }); } } Tudo funciona muito bem. Mas eu […]

O que é “callback hell” e como e por que o RX resolve isso?

Alguém pode dar uma definição clara juntamente com um exemplo simples que explica o que é um “inferno de retorno de chamada” para alguém que não conhece JavaScript e node.js? Quando (em que tipo de configurações) o “problema do inferno de retorno de chamada” ocorre? Por que isso ocorre? O “callback hell” está sempre relacionado […]

Angular2 http.get (), map (), subscribe () e padrão observável – compreensão básica

Agora tenho uma página inicial onde tenho três links. Uma vez que você clica no último link ‘amigos’, o componente apropriado de amigos é iniciado. Lá, eu quero buscar / obter lista dos meus amigos divididos em arquivos friends.json. Até agora tudo funciona bem. Mas eu ainda sou um novato para o serviço HTTP do […]

Como posso fechar uma lista suspensa clicando fora?

Gostaria de fechar a lista suspensa do meu menu 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 […]

Não é possível o erro de tratamento adequado no ajax do rxjs

Eu escrevo o aplicativo em React um Redux e eu tenho um caso que eu tenho que enviar pedido para algum recurso quando a ação específica foi chamada e resposta do tipo ‘text/html’ gravar no estado. Esse recurso pode retornar status 200 ou 404 e não posso escrever o teste correto para o caso com […]

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?