javascript - Node JS SSE: Το σφάλμα του παρατηρητή RxJs αγνοείται ενώ μοιράζεται μια συνδρομή
Υπάρχει ένα τέλος SSE που μοιράζεται μια συνδρομή εάν ο καταναλωτής με το ίδιο κλειδί είναι ήδη εγγεγραμμένος. Εάν υπάρχει ενεργή συνδρομή, τα δεδομένα αντλούνται από άλλο πελάτη.
Το πρόβλημα είναι ότι η εξωτερική συνδρομή φαίνεται να μην ανιχνεύει ποτέ το
Διαβάστε περισσότερα →angular - Δυναμική προσθήκη στην ουρά των RXJS Observables
Ο στόχος είναι να προστεθεί δυναμικά η ουρά των αιτήσεων HTTP και να χειριστεί η ουρά ως μία αίτηση. Ας δείξω πρώτα την τρέχουσα κατάσταση.
συστατικό.ts
public ngOnInit(): void { this.service.touched .pipe( filter(res => !!res), Διαβάστε περισσότερα →javascript - Πώς να ανανεώσετε χειροκίνητα ένα χρονοδιακόπτη rxjs και να ενημερώσετε τις παραμέτρους του observable;
Κάνω την σελιδοποίηση μιας ιστοσελίδας που εμφανίζει δεδομένα ενημερωμένα κάθε 2 λεπτά από ένα API (το API έχει σελιδοποίηση αλλά χρειάζεται να κάνω τη δική μου σελιδοποίηση για να εμφανίσω τα δεδομένα όπως θέλω, παράδειγμα: 100 στοιχεία ανά σελίδα, σελίδα αριθ
Διαβάστε περισσότερα →typescript - Rxjs Observable πίνακας επιλογής μεταξύ των δεδομένων τιμών εκκίνησης και λήξης
Έχω έναν παρατηρήσιμο πίνακα που μοιάζει έτσι:
persons$: Observable<Person[]> = new Observable<Person[]>(); private personSource: BehaviorSubject<Person[]>; constructor() { this.personSource = new BehaviorSubject<Person[]>([ new Person('M Διαβάστε περισσότερα →angular - Πολλαπλές διαδοχικές κλήσεις API με RxJs
Χρειάζομαι να κάνω διαδοχικές κλήσεις API χρησιμοποιώντας RxJs. Το θέμα είναι ότι το πρώτο Observable εκπέμπει έναν πίνακα, για κάθε στοιχείο αυτού του πίνακα θα πρέπει να ορίσω μια προσαρμοσμένη διεύθυνση URL προκειμένου να κάνω την επόμενη κλήση. Στη δεύτερη κλήση θα πρέπει να ελέγξω ορισμένες συνθήκες και να επιστρέψω Observable. Η ερώτησή
Διαβάστε περισσότερα →typescript - Αναδημιουργία του event contextmenu σε RxJS
Θέλω να αναδημιουργήσω το γεγονός contextmenu από τα γεγονότα αφής στο RxJS επειδή το iOS δεν υποστηρίζει το γεγονός contextmenu στην αφή.
Με απλή γλώσσα, αυτό το παρατηρήσιμο θα πρέπει να εκπέμπει όταν:
- το γεγονός touchstart συνέβη
- για 2000ms (ουσιαστικά παρατεταμένο πάτημα)
- ακολουθείται από touchend
typescript - Ποιος είναι ο σκοπός των εμφωλευμένων χειριστών map του RxJS;
Αυτή τη στιγμή παρακολουθώ ένα διαδικτυακό μάθημα Angular και συνειδητοποίησα ότι το RxJS χρησιμοποιείται αρκετά ευρέως στην ανάπτυξη ιστοσελίδων. Έκανα κάποιες δοκιμές και συνάντησα έναν εμφωλευμένο τελεστή map και μπορώ κάπως να καταλάβω τι συμβαίνει, αλλά δεν φαίνεται να μπορώ να βρω πολλές πληροφορίες γι' αυ
Διαβάστε περισσότερα →typescript - Υπάρχει κάποιος τελεστής rxjs που εκπέμπει την πιο πρόσφατη τιμή κατά τη συνδρομή και συνεχίζει να εκπέμπει νέες τιμές;
Χρειάζομαι να δημιουργήσω έναν τελεστή rxjs τον οποίο θα ονομάσω latest. Ακολουθεί ένα παράδειγμα test με Karma που δείχνει τη χρήση:
const root = new Subject<string>(); const inner = new Subject<number>(); const o Διαβάστε περισσότερα →javascript - Χρήση RxJS fromEvent και @ViewChild έναντι του keyup event και RxJS Subject για αλλαγές τιμών πεδίου εισαγωγής
Έχω ένα απλό στοιχείο που εκτελεί αναζήτηση χρησιμοποιώντας τις τιμές που πληκτρολογούνται σε ένα κουτί αναζήτησης. Βρήκα δύο διαφορετικούς τρόπους να το κωδικοποιήσω και και οι δύο λειτουργούν.
Η Μέθοδος 1 χρησιμοποιεί το fromEvent από
Διαβάστε περισσότερα →Typescript: RXJS `distinctUntilChanged` δεν λειτουργεί με αυστηρό/πρώτο όρισμα undefined
Ο παρακάτω κώδικας δεν λειτουργεί:
let observable: Observable<{ key: number }> = of({ key: 123 }); observable.pipe( distinctUntilChanged(undefined, v => v.key) );Αν και υπάρχει υπερφόρτωση:
export function Διαβάστε περισσότερα →