Vyhledávání na webu
angular - Vrátit výsledek observable s combineLatest a Rxjs
Přeji si získat výsledek pozorovatelného objektu, který odečte výchozí hodnotu pokaždé, když se hodnota změní
Pokaždé, když se hodnota změní, odečte výchozí hodnotu od nové hodnoty zadané do vstupního pole
Například výchozí hodnota je 5.
Do vstupního pole zadám 4
Výsledek
Přečtěte si více →angular - Jak získat přístup k Rx.Scheduler.immediate přes rxjs pomocí SystemJS/Angular2?
Chtěl bych ve svém projektu Angular2 použít ImmediateScheduler z RxJS.
Nicméně, v mé instalaci RxJS toto neexistuje. Používám „rxjs“: „5.0.0-beta.12“ v mém souboru package.json, což je požadováno Angular 2.1.2.
Když se podívám do složky node_modules/, najdu složku ‚rxjs‘ a složku ‚rx‘. ImmediateScheduler není součástí ‚rxjs‘, ale ‚rx‘. Mohu jej tam najít v ‚rx/dist/rx.lite.js‘ nebo dokonce v ‚rx/ts/rx/rx-lite.ts‘ jako TypeScript, který používám.
Snažím se to importovat do svéh
Přečtěte si více →typescript - Rxjs: zkrácený zápis pro vytvoření observable z hodnoty nebo observable
Používám rxjs s TypeScriptem. Napsal jsem následující dvě jednoduché funkce. Ale myslím, že rxjs už má takovou funkcionalitu. Má rxjs?
export function isObservable(value: any): value is Observable<any> { return value instanceof Obse Přečtěte si více →typescript - Firebase a RxJS
Vytvořil jsem funkci, která poslouchá události hodnot:
getUnreadMessages() : Observable<any>{ return new Observable(observer =>{ firebase.database().ref('messages/' + this.userService.getUserID()).on("value", (snapshot : any) =>{ let count = 0; ...some more logic here... observer.next(count); observer.complete(); }, (error) =>{ observer.error(error); }) }) }Když se databáze změ
Přečtěte si více →angular - operátory RXJS nefungují s firebase
Používám operátory RXJS s firebase observable (distinct a filter). Toto je můj firebase strom zde. Toto je můj kód:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) return p.goog Přečtěte si více →javascript - Typescript modul řeší 'rxjs' odlišně ve stejném souboru
Strávil jsem hodiny tím, že jsem chodil dokola, takže je čas na další tajemnou otázku.
Jsem uvnitř monorepa lerna, se dvěma podsložkami, ProjectA a ProjectB.
ProjectA má závislost na rxjs, stejně jako Project
Přečtěte si více →typescript - RxJS6: resetovat tok po dokončení
Trochu si hraju s RxJS 6. Snažím se implementovat dragstart, dragmove a dragend. Toto je kód, který mám zatím.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from 'rxjs/internal Přečtěte si více →typescript - S RxJs v Angularu potřebuji ukončit pouze Observables vytvořené v komponentě?
V zásadě si stále nejsem úplně jistý ohledně úklidu reaktivního kódu v komponentách Angularu. Jsou následující pravidla správná a dostatečná?
Moje pravidla pro reaktivní komponentu:
v manuálu x.subscribe():
- pokud používáte x.takeUntil(...) nebo podobnou konstrukci, pak není potřeba žádné ruční čištění
- pokud je v rozsahu komponenty zavoláno x.complete(), pak není potřeba žádné ruční čištění
- jinak manuálně .unsub Přečtěte si více →
typescript - rxjs stránkování s odběrem každé stránky
Dotazujeme se na graphql přes websocket, abychom měli odběr seznamu entit. Používáme stránkování, protože seznam má být možné rolovat neomezeně. Také chceme vidět změny provedené v databázi v reálném čase v seznamu na front-endu.
Tento seznam lze filtrovat, třídit a stránkovat.
Máme třídu SelectParams, která nám s tím pomáhá:
export class SelectParams { page = 0; query = ''; sort: Sort = { s Přečtěte si více →typescript - Angular 6 Chyba při použití RxJS: Nelze číst vlastnost 'call' z undefined
Snažím se migrovat aplikaci Angular 5 na Angular 6 a mám tento jeden blok kódu RxJS, který mě zmátl. Hledal jsem na Googlu a pročetl dokumentaci RxJS dostatečně na to, abych věděl, že bych měl používat .pipe, ale syntaxi nemohu úplně zvládnout.
Kód vrací výsledky z volání API,
Přečtěte si více →