kombinieren RxJs Observable Array

Question

Ich versuche, Infinite-Scroll in einer Ionic2 + Meteor Mobile App, die die Kontakte listet. Im folgenden Code gibt die Funktion findContacts() 10 Kontakte gleichzeitig zurück. Kontakte: Beobachtbar;

Dieser Code wird jedes Mal aufgerufen, wenn der Benutzer zum Ende der Liste blättert und die nächsten 10 Kontakte erhält. Aber das Problem ist, dass es sich nicht um die bereits aufgelisteten Kontakte handelt. Es zeigt nur die neu gezogenen 10 Kontakte. Ich habe versucht, Observable.concat, aber es gibt keine gewünschten Ergebnisse. Wenn ich MergeMap ausprobiert habe, geht es indifferente Schleife und Fehler raus. Könnten Sie mir bitte mitteilen, wie man Observable Array-Objekte kontrainieren kann? Jede Hilfe wird sehr geschätzt. Ich stecke jetzt seit mehr als einer Woche mit diesem Problem fest. Danke.

Answer 1

Sie können dies, indem Kontakte als Array erreichen

contacts: Array<any>= [] 
findContacts() :Observable<Contact[]> { 
    /* logic to pull Contacts is here ...*/ 
    } 

    this.contactsSub = MeteorObservable.subscribe('contacts', options).subscribe(() => { 
     MeteorObservable.autorun().subscribe(() => { 
      this.findContacts().subscribe(data => { 
       this.contacts = this.contacts.concat(data); 
     }); 
     }); 
    });