angular - Zwróć wynik obserwowalnego za pomocą combineLatest i Rxjs

Chcę otrzymać wynik obserwowalnego, który odejmuje wartość domyślną za każdym razem, gdy wartość się zmienia

Za każdym razem, gdy wartość się zmienia, odejmuje wartość domyślną od nowej wartości wprowadzonej w polu input

Na przykład wartość domyślna to 5.

Wprowadzam 4 w pole tek

Czytaj więcej →

angular - Jak uzyskać dostęp do Rx.Scheduler.immediate za pomocą rxjs używając SystemJS/Angular2?

Chciałbym użyć ImmediateScheduler z RxJS w moim projekcie Angular2.

Jednak w mojej instalacji RxJS tego nie ma. Używam "rxjs": "5.0.0-beta.12" w moim pliku package.json, co jest wymagane przez Angular 2.1.2.
Przeglądając folder node_modules/ znajduję folder 'rxjs' i folder 'rx'. ImmediateScheduler nie jest częścią 'rxjs', lecz 'rx'. Mogę go tam znaleźć w 'rx/dist/rx.lite.js' lub nawet w 'rx/ts/rx/rx-lite.ts' jako TypeScript, którego używam.

Próbując zaimportować to w moim plik

Czytaj więcej →

typescript - Rxjs: skrót do tworzenia obserwowanego z wartości lub obserwowalnego

Używam rxjs z TypeScriptem. Napisałem następujące dwie proste funkcje. Ale przypuszczam, że rxjs już ma taką funkcjonalność. Czy rxjs ją ma?

export function isObservable(value: any): value is Observable<any> { return value instanceo

Czytaj więcej →

typescript - Firebase i RxJS

Stworzyłem funkcję, która nasłuchuje zdarzeń wartości:

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); }) }) }

Kiedy baza danych si

Czytaj więcej →

angular - operatory RXJS nie działają z firebase

Używam operatorów RXJS z obserwowalnym Firebase (distinct i filter). Oto moja struktura Firebase. Oto mój kod:

let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) return p.googleId;

Czytaj więcej →

javascript - Moduł Typescript rozwiązuje 'rxjs' inaczej w tym samym pliku

Spędziłem godziny, krążąc w kółko, więc czas na kolejne tajemnicze pytanie.

Jestem wewnątrz mono repozytorium lerna, z dwoma podprojektami, ProjectA i ProjectB.

ProjectA ma zależność od rxjs, podobnie jak Pro

Czytaj więcej →

typescript - RxJS6: zresetuj strumień po zakończeniu

Trochę bawiłem się RxJS 6. Próbuję zaimplementować dragstart, dragmove i dragend. Oto kod, który mam do tej pory.

import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from 'rxjs/inter

Czytaj więcej →

typescript - Czy z RxJs w Angularze muszę kończyć tylko Observables utworzone w komponencie?

W zasadzie nadal nie jestem do końca pewien dotyczącego sprzątania reaktywnego kodu w komponentach Angular. Czy następujące zasady są poprawne i wystarczające?

Moje zasady dla komponentu reaktywnego:

• w podręczniku x.subscribe():

  • jeśli używasz x.takeUntil(...) lub podobnej konstrukcji, to nie ma potrzeby ręcznego sprzątania
  • jeśli x.complete() zostanie wywołane w zakresie komponentu, to nie ma ręcznego sprzątania
  • w p
    Czytaj więcej →

typescript - paginacja rxjs z subskrypcją dla każdej strony

Zapytujemy graphql przez websocket, aby mieć subskrypcję listy encji. Używamy paginacji, ponieważ lista powinna być przewijalna w nieskończoność. Chcemy też widzieć zmiany wprowadzone w bazie danych w czasie rzeczywistym na liście w interfejsie użytkownika.

Ta lista może być filtrowana, sortowana i paginowana.

Mamy klasę SelectParams, która pomaga nam to zrobić:

export class SelectParams { page = 0;

Czytaj więcej →

typescript - Angular 6 Błąd użycia RxJS: Nie można odczytać właściwości 'call' niezdefiniowanego

Próbuję przenieść aplikację Angular 5 do Angular 6 i mam ten jeden fragment kodu RxJS, który mnie zaskakuje. Szukałem w Google i czytałem dokumentację RxJS wystarczająco, aby wiedzieć, że powinienem używać .pipe, ale nie mogę do końca opanować składni.

Kod zwraca wyniki z wywo

Czytaj więcej →