Angular 2 Observables - Leere Antwort auf Aktion zeigt immer noch Daten im Array

Question

Ich habe diese Funktion, die einige Benutzerdaten aus Firebase aggregiert, um eine "Freundschaftsanfrage" Ansicht zu erstellen. Beim Laden der Seite wird die korrekte Anzahl der Anfragen angezeigt. Wenn ich auf "Akzeptieren" klicke, wird die korrekte Verbindungsanforderung aktualisiert, die dann signalisiert, diese Funktion erneut auszuführen, da der Benutzer sie abonniert hat. Das einzige Problem besteht darin, dass, sobald alle Freundschaftsanfragen akzeptiert sind, der letzte verbleibende Benutzer in der Liste bleibt und nicht verschwindet, obwohl sie bereits akzeptiert wurden.

Hier ist die Funktion Ich verwende die Anfragen zu erhalten:

getConnectionRequests(userId) { 

    return this._af.database 
     .object(`/social/user_connection_requests/${userId}`) 

     // Switch to the joined observable 
     .switchMap((connections) => { 

     // Delete the properties that will throw errors when requesting 
     // the convo keys 
     delete connections['$key']; 
     delete connections['$exists']; 

     // Get an array of keys from the object returned from Firebase 
     let connectionKeys = Object.keys(connections); 

     // Iterate through the connection keys and remove 
     // any that have already been accepted 

     connectionKeys = connectionKeys.filter(connectionKey => { 

      if(!connections[connectionKey].accepted) { 
      return connectionKey; 
      } 
     }) 

     return Observable.combineLatest(
      connectionKeys.map((connectionKey => { 

       return this._af.database.object(`/social/users/${connectionKey}`) 
      })) 
     ); 
     }); 
    } 

Und hier ist der entsprechende Code in mein Eckige 2 Ansicht (mit Ionic 2):

ionViewDidLoad() { 

    // Get current user (via local storage) and get their pending requests 
    this.storage.get('user').then(user => { 
     this._connections.getConnectionRequests(user.id).subscribe(requests => { 

     this.requests = requests; 
     }) 

    }) 
    } 

Ich fühle mich Ich mache etwas falsch mit meiner beobachtbaren und deshalb ist dieses Problem passiert. Kann jemand das vielleicht etwas beleuchten? Danke im Voraus!

Answer 1

Ich denke, Sie haben es in Ihrem Kommentar genagelt. Wenn connectionKeys ein leeres Array ist Observable.combineLatest Aufruf ist nicht geeignet:

import 'rxjs/add/observable/of'; 

if (connectionKeys.length === 0) { 
    return Observable.of([]); 
} 
return connectionKeyObservable.combineLatest(
    connectionKeys.map(connectionKey => 
    this._af.database.object(`/social/users/${connectionKey}`) 
) 
);