Existe-t-il un équivalent flatMap qui renvoie l'observable interne?

Question

J'utilise AngularFire2 et je fais quelque chose comme ceci:

// assume loggedInUserId is Observable<string> 
var firebaseList = loggedInUserId 
    .flatMap((userId) => this.db.list(this.firebaseRoot.child(userId))) 

this.db.list retourne un FirebaseListObservable<any[]> avec des fonctions pratiques comme push, delete, etc., mais flatMap ne retourne que Observable<any[]> donc je ne suis pas accès à leur.

Existe-t-il un équivalent à flatMap qui renvoie le FirebaseListObservable? Ou est-ce impossible?

Answer 1

Vous pouvez essayer carte d'utilisation à la place, il va conserver l'observable d'origine de firebase

Modifié: peut-être casting est la réponse

var firebaseList = loggedInUserId.flatMap((userId) => 
this.db.list(this.firebaseRoot.child(userId))) as FirebaseListObservable<any> 
firebaseList.flatMap(items=>ob.push({foo:'bar'})).subscribe() 

Pour le changement à droite en tapant s'il vous plaît voir ce How do I use .take on FirebaseListObservable?

Answer 2

Est-ce que cela aide?

loggedInUserId.subscribe(userId => { 
    var firebaseList = this.db.list(this.firebaseRoot.child(userId)) 
    // do stuff with the list 
} 

Modifier

Est-ce que switchMap retourne le type dont vous avez besoin?

const firebaseList = 
    loggedInUserId.switchMap(userId => 
    this.db.list(this.firebaseRoot.child(userId)) 
) 

Answer 3

Vous pouvez créer un convertisseur

const mapToFirebaseListObservable = (source) => { 
    new FirebaseListObservable(observer => { 
    return source.subscribe({ 
     next(x) { observer.next(x); }, 
     error(err) { observer.error(err); }, 
     complete() { observer.complete(); } 
    }) 
    }) 
} 

Utilisez-le avec

var firebaseList = mapToFirebaseListObservable(
    loggedInUserId 
    .flatMap((userId) => this.db.list(this.firebaseRoot.child(userId))) 
) 

Je ne l'ai pas essayé sur une firebase installation complète, de sorte que vous pouvez obtenir un newing d'erreur up FirebaseListObservable, mais je l'ai essayé avec un Observable avec une fonction ajoutée

const newObservable = new Observable(observer => { 
    ... 
}) 
newObservable['myFn'] =() => 'from myFn' 

et la fonction est présente et appelable sur la sortie.

EDIT: Cela semble également travailler

const toInner = (source) => { 
    return source.operator && source.operator.project 
    ? source.operator.project() 
    : source 
} 

Utilisation:

var firebaseList = toInner(
    loggedInUserId 
    .flatMap((userId) => this.db.list(this.firebaseRoot.child(userId))) 
) 

Il pourrait également être transformé en un opérateur enchaîné

const toInner = function() { 
    const source = this 
    return source.operator && source.operator.project 
    ? source.operator.project() 
    : source 
} 
Observable.prototype.toInner = toInner; 

Voir aussi here pour Rxjs v5.50beta sur les modifications apportées à la création d'opérateurs .