Resultados da pesquisa a pedido "rxjs5"
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 ...
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 obter um serviço de debounce no evento keyup de entrada em angular2 com rxjs
Estou tentando ligar para um serviço no evento de key-up de entrada. O HTML <input placeholder="enter name" (keyup)='onKeyUp($event)'>Abaixo está oonKeyUp() função onKeyUp(event) { let observable = Observable.fromEvent(event.target, ...
Subject vs AnonymousSubject
Qual é a diferença entreSubject eAnonymousSubject noRxJS 5? Pesquisei na internet, mas não encontrei nenhuma informação sobreAnonymousSubject. Encontrei um exemplo na web Subject.create(observer, observable);Olhando para o código-fonte rxjs, vi ...
RxJS: ngOnDestroy () do componente angular takeUntil ()
tl; dr: Basicamente, quero me casar com AngularngOnDestroy com os RxjstakeUntil() operador. -- isso é possível? Eu tenho um componente Angular que abre várias assinaturas Rxjs. Eles precisam ser fechados quando o componente é destruído. Uma ...
Como obter eventos observáveis do RxJS em tempo zero?
Estou coletando todos os eventos de um Observável para umdata matriz: const obs$ = Rx.Observable .interval(500) .take(4); let data = []; const start = performance.now(); obs$.subscribe( value => { data.push({ time: performance.now() - start, ...
Rxjs - Como extrair vários valores dentro de uma matriz e devolvê-los ao fluxo observável de forma síncrona
Eu criei umRx.Observable de um fluxo de eventos: Rx.Observable.fromEvent(recognizeStream, 'data')No qual cada evento de dados se parece com isso: { error: null, alternatives: [result1, result2, result3] }Eu quero extrair todo valor dentro da ...
rxjs 5 publishReplay refCount
Não consigo descobrir comopublishReplay().refCount() trabalho. Por exemplo (https://jsfiddle.net/7o3a45L1/ [https://jsfiddle.net/7o3a45L1/]): var source = Rx.Observable.create(observer => { console.log("call"); // expensive http request ...
Pipe RxJS observável para o sujeito existente
Existe um assunto existente que está em uso: const fooSubject = new BehaviorSubject(null);E há outro observável (outro assunto neste exemplo): const barSubject = new Subject(); barSubject.subscribe( value => fooSubject.next(), err => ...
O que a assinatura faz e como ela está relacionada ao Observable?
Eu sou novo no Angular e o tutorial que segui tem o termo "Observable". O tutor explicou, mas eu não entendi completamente. O que é umObservablee por que sempre precisamos ligarobservable.subscribe()? O quesubscribe() realmente faz?