Filtrage de la liste vide par RxJava et utilisation de firstOrDefault

Question

J'essaie de filtrer une liste qui pourrait être vide ou non (ou l'élément ne figure pas dans la liste). inboxData est rempli par un autre observable:

private BehaviorSubject<InboxResponse> inboxData = BehaviorSubject.create(); 

public Observable<Item> getInboxItem(String id) { 
    return inboxData 
     .flatMap(response -> Observable.from(response.getData())) 
     .filter(item -> item.getId().equals(id)) 
     .firstOrDefault(null); 
} 

Dans ce cas, si response.getData() est vide FirstOrDefault fonctionne jamais. Mais pourquoi? Il indique clairement qu'il vous redonne la valeur par défaut si l'observable précédent n'émet rien.

Answer 1

firstOrDefault émet la valeur par défaut si le flux complète sans éléments étant passé par l'observable. Pour que votre flux se termine, le BehaviorSubject doit signaler l'achèvement. Comme il n'y a aucune indication que cela arrive, il ne réalisera jamais qu'il doit envoyer la valeur par défaut.

La solution consiste à déplacer le filter et firstOrDefault à l'intérieur de la flatMap si la fin de la liste fournie par getData finit par remplir le flux interne. Notez que si vous utilisez RxJava2 comme vos balises le suggèrent, null ne peut jamais être un élément du flux, donc le transmettre par défaut provoquerait une exception.

Answer 2

public Observable<Item> getInboxItem(String id) { 
    return inboxData 
     .flatMap(response -> Observable.from(response.getData())) 

À ce stade, response.getData() renvoie null, n'est-ce pas?

 .filter(item -> item.getId().equals(id)) 

Cela signifie que item est null. Donc, item.getId() lance un NullPointerException. Une erreur de ce type est immédiatement transmise au gestionnaire onError de l'abonné. La méthode firstOrDefault ne sera même plus appelée, car le flux est immédiatement terminé.

 .firstOrDefault(null); 
}