typescript - Στην Angular2 με Rxjs οι παρατηρητές δεν ρυθμίζονται αν είναι περισσότεροι του ενός

Προσπαθώ να ορίσω πολλούς παρατηρητές από τον κατασκευαστή μου. Μόνο ένας ορίζεται και οι υπόλοιποι δεν ορίζονται, παραμένουν ως null (αμετάβλητοι).

Δεν είμαι σίγουρος γιατί το κάνει αυτό.

export class gq { /** * This is observable data service https://coryrylan.com/blog/angular-2-observable-data-services */ constructor(private api: Api) { this._ = { // just to define object here, else it will give error observer: {

Διαβάστε περισσότερα →

typescript - rxjs5 - δεν μπορεί να βρεθεί κατασκευαστής WebSocket

Προσπαθώ να κάνω κάτι βασικό, αλλά μου ξεφεύγει εντελώς. Προσπαθώ να δημιουργήσω ένα Observable από rxjx/observable/dom/webSocket στο RxJS5, αλλά δεν χρησιμοποιώ typescript ή es6 modules... απλώς το καλό παλιό commonJS. Κατάφερα να διορθώσω το Observable σωστά σύμφωνα με τα έγγραφα, αλλά όποτε προσπα

Διαβάστε περισσότερα →

javascript - Αντιγραφή δεδομένων απόκρισης από rxJs σε Angular2/Typescript

Χρησιμοποιώ το Observable από το rxJS στην εφαρμογή μου Angular2 με TypeScript. Θα ήθελα να πάρω ένα αντίγραφο των δεδομένων της απάντησης του http get.

Υπηρεσία :

getSizes(sku: number): Observable<SizeList[]> { let api = this.host + this.routes.sizes + sku; retu

Διαβάστε περισσότερα →

javascript - RxJs: http.get λαμβάνει έναν πίνακα, αλλά θέλω ο συνδρομητής να λάβει μεμονωμένα στοιχεία

Γράφω μια εφαρμογή Angular2 (RC5) που χρησιμοποιεί ένα RESTful API backend του NodeJS.

Μία από τις διαδρομές του backend επιστρέφει έναν πίνακα με 'Υποψηφίους':

exports.list = function (req, res, next) { const sort = req.query.sort || nu

Διαβάστε περισσότερα →

javascript - Πώς να αλυσίσετε πολλαπλές κλήσεις .map() σε προηγούμενα στοιχεία χρησιμοποιώντας rxjs

Στο παρακάτω παράδειγμα αναρωτιόμουν πώς θα προχωρούσατε στην εκτέλεση δύο λειτουργιών στην ίδια απάντηση από το .switchMap().

Στο παράδειγμα έβαλα το δεύτερο .map το οποίο είναι σαφώς λάθος αλλά κάπως αποτυπώνει τι θέλω να κάνω. Πώς θα προχωρήσω στο να καλέσω δύο συναρτήσεις; Επίσης, ό

Διαβάστε περισσότερα →

npm - RxJS Typescript: Η ιδιότητα 'reduce' δεν υπάρχει στον τύπο 'Observable'

Έχω αυτό το μικρό απόσπασμα

const observable:Observable<number> = Observable.from([1, 2, 3]) .reduce((sum: number, number: number) => { return sum + number }, 0) observable.subscribeOnNext((sum) => console.log(sum))

Λειτουρ

Διαβάστε περισσότερα →

angular - RxJs: Είναι σωστό να χρησιμοποιείτε try/catch μέσα στο subscribe();

Ας υποθέσουμε ότι έχουμε μια εφαρμογή Angular 2. Κάποια μέθοδος υπηρεσίας επιστρέφει δεδομένα μέσω του post(), όπου έχουμε catch() για να πιάσουμε πιθανά σφάλματα.

Στο component έχουμε εγγραφεί στα δεδομένα του Observable:

.subscribe( ()=> { // some code } )

ας υποθέσουμε ότι προσπαθώ να πάρω κάποια δεδομένα από το localStorage ή κάποια άλλη κρίσιμη λειτουργία. Μπορώ να προσθέσω δήλωσ

Διαβάστε περισσότερα →

typescript - Εξαγωγή ενός προσαρμοσμένου τελεστή RxJS σε μια βιβλιοθήκη Angular

Ο παρακάτω προσαρμοσμένος τελεστής RxJS (στην πραγματικότητα απλώς ένα ισοδύναμο .filter για επίδειξη) δηλώνεται αυτή τη στιγμή σε ένα συστατικό Angular 4.0.0-rc.2.

declare module 'rxjs/Observable' { interface Observable<T> { restrictToCommand<U>(f: (x: T) => U): Observ

Διαβάστε περισσότερα →

javascript - Angular 2 - rxjs - Πίνακας Observable

Στο πρότυπό μου εγγράφομαι σε έναν παρατηρήσιμο πίνακα ως εξής:

<div *ngFor="let item of activities | async">...</div>

Αλλαγήσα την πίνακα δραστηριοτήτων μου σε έναν παρατηρήσιμο πίνακα επειδή μου αρέσει η ιδέα της προβολής να εγγράφεται και να διαγράφεται από τα παρατηρήσιμα μου αντικείμενα.

Η ερώτησή

Διαβάστε περισσότερα →

javascript - Angular2 RxJS - διαχωρισμός συλλογής διευθύνσεων URL για ανάκτηση σε μικρότερα κομμάτια

Χρησιμοποιώ το Angular2.4.8. Έχω μια συλλογή από URL προς ανάκτηση (δεκάδες από αυτά). Αυτή τη στιγμή τα ανακτώ όλα ταυτόχρονα, αλλά συχνά συμβαίνει ο διακομιστής να μην μπορεί να χειριστεί τόσα πολλά αιτήματα ταυτόχρονα. Ο τρέχων κώδικας:

let collectionsRequests =

Διαβάστε περισσότερα →