Resultados da pesquisa a pedido "rxjs"
RxJs observáveis com WebSocket
Meu aplicativo angular usa um soquete da web para se comunicar com o back-end. No meu caso de teste, tenho 2 componentes de cliente. O timer Observable imprime dois IDs de cliente diferentes conforme o esperado. Cada ngOnInit () também imprime ...
RxJs Ramificação se outra lógica
onSave() { // event handler const save$ = combineLatest(this.configData.data, this.layerService.layerData) .pipe( filter(([configData]) => !_.isEmpty(configData)), take(1), tap(_ => this.loadingService.showLoading()), map(data => ...
Coletar RxJS Observável na Matriz
Eu gostaria de usar o RxJS para "unir" o mundo assíncrono dos eventos com o mundo sincronizado. Especificamente, quero criar uma função que retorne uma matriz de eventos coletados durante algum intervalo de tempo. Eu posso criar o Observable que ...
o que é um `Scheduler` no RxJS
Eu já vi o termoAgendador [https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/schedulers/scheduler.md#rxschedulernow-schedule-schedulerelative-scheduleabsolute] com muita frequência na documentação. Mas, o que esse termo significa? ...
RxJs Como lidar com eventos de documento
Começou a usar RxJs. Não foi possível encontrar uma maneira de contornar esse problema. Eu tenho um controle arrastável: startDrag = rx.Observable.fromEvent(myElem,'mousedown')agora, porque o controle é muito pequenomousemove emouseup os eventos ...
Diferença entre `share ()` e `publish (). RefCount ()`
Qual é a diferença prática entreobservable.publish().refCount() eobservable.share(). O que seria um exemplo de um cenário em que não queremos usarshare?
Recebendo notificações feitas de observáveis criados usando o switch
No exemplo abaixo,foo recebe dados debar ainda ignora quandobar completa.foo é completado quandobaz completa, que não é o comportamento que desejo. var baz = Rx.Observable.interval( 50 ).take( 10 ); var foo = baz .select(function (x) { var bar = ...
RxJS: Dividindo um resultado de matriz de Observable.fromPromise
Estou usando o RxJS aqui e não consigo superar issoaparentemente questão simples. rx.Observable .from([1,2,3,54,3,22,323,23,11,2]) .distinct() .subscribe(function next (x) { console.log('Next'); console.log(x); }, function error (x) ...
Modelagem RxJS se mais controlar estruturas com operadores Observables
É possível modelar estruturas de controle if / else via operadores RxJS. Tanto quanto eu entendi, poderíamos usar Observable.filter () para simular uma ramificação IF, mas não tenho certeza se simulamos uma ramificação ELSE por meio de qualquer ...
Transforme várias solicitações de ajax em Observables com o RxJS
Estou lutando com algo - o que acho que significa que eu entendi mal e estou fazendo algo bobo Eu tenho um observável e preciso usá-lo para criar algum objeto, enviá-lo ao servidor para processamento, combinar um resultado do servidor com o ...