Resultados da pesquisa a pedido "rxjs"
RxJs Observável de vs de
É a única diferença entreObservable.of eObservable.from o formato dos argumentos? Como oFunction.prototype.call eFunction.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() => {})
Como faço para parar Observable.Timer () ou Observable.Interval () automaticamente após determinado período de tempo
public function(id: number) { this.periodicCheckTimer = Observable.timer(10000, 5000).subscribe( () => { let model = this.find(id); if (model['isActivated']) { this.periodicCheckTimer.unsubscribe(); } }); }Quero parar o cronômetro automaticamente ...
Observável rxJS não alcançando assinatura
Estou com Angular 2 e RxJS e estou tendo dificuldades para configurar um sistema simples de observação. Pelo que entendi, o operador do é usado para efeitos colaterais, e você coloca o código para lidar com os resultados retornados pelo ...
Precisamos cancelar a assinatura do observável que termina / com erros?
Quando eu sei que o observável definitivamente estará completo (comcomplete ou umerror notificação)antes meu componente / classe está fora do escopo, ainda preciso cancelar a assinatura dele para evitar vazamentos de memória? Em outras palavras, ...
Como converter ou atribuir facilmente um Observável a um Assunto de Comportamento, para que outro componente possa compartilhá-lo
Eu sou novo na programação de estilo Observable. Tenho uma pergunta: quero compartilhar informações do usuário no aplicativo entre o componente - e uso o BehaviorSubject para compartilhar essas informações. Isso é inspirado no compartilhamento do ...
Inscrever-se para vários Observáveis em Angular 2
Meu aplicativo Angular 2 possui 2 métodos [GetCategories () e GetCartItems ()] em um serviço, e esses dois métodos retornam Observables. Para invocar esses dois métodos um após o outro do meu componente, escrevi o código abaixo ngOnInit() { ...
Como testar uma função que retorna um observável usando intervalos de tempo no rxjs 5?
Por exemplo, eu tenho uma função como esta: export function timeRange(start: number, end: number): Rx.Observable<number> { return Rx.Observable.interval(1000) .map(n => n + start) .take(end - start + 1) }E eu tive um teste de unidade que ...
Rx.Subject é um observável quente?
O código const a = new Rx.Subject().do(x => console.log('a')) const b = a.mapTo(0) const c = a.mapTo(1) const d = Rx.Observable.merge(b, c) d.subscribe(x => console.log('d')) a.next(3)E a saída a d a dPor que uma impressão foi impressa duas ...
Armazenamento em cache reativo do serviço HTTP
Estou usando o RsJS 5 (5.0.1) para armazenar em cache no Angular 2. Funciona bem. A carne da função de armazenamento em cache é: const observable = Observable.defer( () => actualFn().do(() => this.console.log('CACHE MISS', cacheKey)) ) ...
Como o RxJS MergeMap funciona?
Eu não entendo o propósito demergeMap em absoluto. Eu ouvi duas "explicações: "É como SelectAll" no LINQ - não."Bem, é uma combinação de RxJSmerge emap"- não (ou não consigo replicar isso).Considere o seguinte código: var obs1 = new ...