javascript - Importovat { map } z 'lodash', 'rxjs', 'ramda' současně, aniž by byla ohrožena čitelnost

Jak lze importovat map nebo merge či jakoukoli jinou funkci z více importů?

import { map } from 'lodash'; import { map } from 'rxjs/operators'; import { map } from 'ramda';

Očividná odpověď je:

import { map

Přečtěte si více →

javascript - Jak implementovat časově vypršelý hot observable v RxJS (nebo obecně v Reactive Extensions)

Rád bych implementoval cache s vypršením času pomocí RxJs. Zde je příklad „běžné“ cache:

//let this represents "heavy duty job" var data = Rx.Observable.return(Math.random() * 1000).delay(2000); //and we want to cache result var cachedData

Přečtěte si více →

javascript - RXJS if s observable jako podmínkou

Chci použít Rx.Observable.if k spuštění jednoho ze dvou observables, pokud se podmíněný observable vyhodnotí na true nebo false.

To, čeho chci dosáhnout, by vypadalo nějak takto:

Rx.Observable.if(conditionalObservable.map(x => x.length > 0), firstObservable, secondObservable).subscribe()

Přečtěte si více →

javascript - Chyba: Nelze najít modul "rxjs/operators" v Ionic Angular

Snažím se spustit svůj projekt Ionic. Fungovalo to bez problémů až do před několika dny, teď ho prostě nemohu spustit, ať dělám cokoli. Objevuje se tato chyba! Zkoušel jsem odstranit Rxjs z package.json a node_modules, také jsem zakomentoval všechna místa, kde jsem Rxjs používal, stále se tato chyba ob

Přečtěte si více →

javascript - RxJS zpoždění (Debounce) s prioritou

Mám problém vymyslet tento proud.

Co hledám, je něco jako debounceTime, ale s prioritou.

Takže pokud mám události ve tvaru { type: 'a', priority: 2 }. Tyto události je potřeba spouštět s debounce několika sekund, ale místo toho, aby byla vyvolána poslední událost, je vyvolána událost s nejvyšší prioritou.

Přečtěte si více →

javascript - RXJS Řetězit závislé observably sekvenčně, ale získávat každé vyzařování pro indikátor průběhu

Čelím problému a snažil jsem se najít řešení pomocí RxJs, ale zdá se, že žádné, které by tomu vyhovovalo, nenacházím...

• Mám 3 různé REST požadavky, které budou volány postupně, a každý z nich potřebuje odpověď předchozího jako argu
  Přečtěte si více →

javascript - RxJS: Jak mohu udělat „if“ s Observables?

Řekněme, že mám dva observably a chci poslouchat změny jednoho observable, pokud druhý splňuje určitou podmínku. Zkoušel jsem to pomocí zip, ale zdá se, že budu upozorněn pouze tehdy, když se oba observably změní, ale já chci být upozorněn na každou změnu jednoho observable, pokud je podmínka toho druhého prav

Přečtěte si více →

javascript - Počítat události během časového období a vracet součet jednou za sekundu v RxJS

Je možné spočítat události během určitého časového období a vydat součet každou sekundu v RxJS? Mám nepřetržitý nikdy nekončící tok událostí. Každou sekundu bych chtěl získat celkový počet událostí za posledních 5 minut. Myšlenka je použít toto k naplnění g

Přečtěte si více →

Jak omezit frekvenci události mousemove v RxJs při použití Angular 2 + TypeScript?

Jsem právě v procesu učení RxJs. Používám Angular2 rc3. Následující stream funguje, ale dává mi příliš mnoho událostí mousemove. Chci je zpomalit pomocí času (throttling) nebo jiného řídicího streamu. Jak to mohu udělat?

Proud pohybu myši bez o

Přečtěte si více →

typescript - Kombinované pipelovatelné operátory s RxJS/Angular

Je možné (nenacházím nic komplexního o tomto), kombinovat více pipovatelných operátorů v jedné funkci, abych ji mohl pipeovat a znovu použít v jiné metodě?

Tady je věc:

public ngOnInit(): void { this.route.url .pipe( switchMap( (ids: UrlSegment[]) => /* http call */),

Přečtěte si více →