angular - Retourner le résultat d'un observable avec combineLatest et Rxjs
Je souhaite obtenir le résultat d'un observable qui soustrait la valeur par défaut à chaque fois que la valeur change
Chaque fois que la valeur change, elle soustrait la valeur par défaut de la nouvelle valeur saisie dans le champ de saisie
Par exemple, la valeur par défaut est 5.
Lire la suite →angular - Comment accéder à Rx.Scheduler.immediate via rxjs en utilisant SystemJS/Angular2 ?
Je voudrais utiliser le ImmediateScheduler de RxJS dans mon projet Angular2.
Cependant, dans mon installation de RxJS, cela n'existe pas. J'utilise "rxjs" : "5.0.0-beta.12" dans mon package.json, ce qui est requis par Angular 2.1.2.
En regardant dans le dossier node_modules/, je trouve un dossier 'rxjs' et un dossier 'rx'. Le ImmediateScheduler ne fait pas partie de 'rxjs' mais de 'rx'. Je peux le trouver là dans 'rx/dist/rx.lite.js' ou même dans 'rx/ts/rx/rx-lite.ts' en TypeScript
typescript - Rxjs : raccourci pour créer un observable à partir d'une valeur ou d'un observable
J'utilise rxjs avec TypeScript. J'ai écrit les deux fonctions simples suivantes. Mais je suppose que rxjs a déjà cette fonctionnalité. Est-ce que rxjs l'a ?
export function isObservable(value: any): value is Observable<any> { return Lire la suite →TypeScript - Firebase et RxJS
J'ai créé une fonction qui écoute les événements de valeur :
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); }) }) }Lorsque la bas
Lire la suite →angular - Les opérateurs RXJS ne fonctionnent pas avec firebase
J'utilise les opérateurs RXJS avec l'observable Firebase (distinct et filter). voici mon arbre Firebase ici. voici mon code :
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) ret Lire la suite →javascript - Le module Typescript résout 'rxjs' différemment dans le même fichier
J'ai passé des heures à tourner en rond, alors il est temps pour une autre question obscure.
Je suis à l'intérieur d'un mono dépôt lerna, avec deux sous-projets, ProjectA et ProjectB.
ProjectA a une dépendance à rxjs
Lire la suite →typescript - RxJS6 : réinitialiser le flux après l'achèvement
J'ai un peu experimenté avec RxJS 6. J'essaie d'implémenter dragstart, dragmove et dragend. Voici le code que j'ai jusqu'à présent.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil Lire la suite →typescript - Avec RxJs dans Angular, dois-je seulement compléter les Observables créés dans le composant ?
En gros, je ne suis toujours pas vraiment sûr du nettoyage du code réactif dans les composants Angular. Les règles suivantes sont-elles correctes et suffisantes ?
Mes règles pour un composant réactif :
sur le manuel x.subscribe() :
- si vous utilisez x.takeUntil(...) ou une construction similaire, alors aucun nettoyage manuel
- si x.complete() est appelé dans le scope du composant alors aucun nettoyage manuel
- sinon fai Lire la suite →
typescript - pagination rxjs avec abonnement à chaque page
Nous interrogeons graphql via websocket pour avoir un abonnement à une liste d'entités. Nous utilisons la pagination puisque la liste est censée être défilable indéfiniment. Nous voulons également voir les modifications apportées à la base de données en temps réel dans la liste sur le front-end.
Cette liste peut être filtrée, triée et paginée.
Nous avons la classe SelectParams qui nous aide à faire cela :
Lire la suite →typescript - Angular 6 Erreur lors de l'utilisation de RxJS : Impossible de lire la propriété 'call' de undefined
J'essaie de migrer une application Angular 5 vers Angular 6 et j'ai ce bloc de code RxJS qui me laisse perplexe. J'ai googlé et parcouru les docs de RxJS suffisamment pour savoir que je devrais utiliser .pipe, mais je n'arrive pas tout à fait à comprendre la syntaxe.
Le code r
Lire la suite →