我正在使用一个外部API,其中有两个函数,一个返回
Maybe
,另一个返回Completable
(请参见下面的代码)。我希望我的函数“saveUser()”返回一个Completable
,这样我就可以使用doOnSuccess()
和doOnError
来检查它。但目前我的代码无法编译。另外,请注意,如果我的“getMaybe”没有返回任何内容,则我希望在我的flatmap中获得一个null值作为参数,以便我可以处理null vs非null情况(如代码所示)。 private Maybe<DataSnapshot> getMaybe(String key) {
// external API that returns a maybe
}
private Completable updateChildren(mDatabase, childUpdates) {
// external API that returns a Completable
}
// I'd like my function to return a Completable but it doesn't compile now
public Completable saveUser(String userKey, User user) {
return get(userKey)
.flatMap(a -> {
Map<String, Object> childUpdates = new HashMap<>();
if (a != null) {
// add some key/values to childUpdates
}
childUpdates.put(DB_USERS + "/" + userKey, user.toMap());
// this returns a Completable
return updateChildren(mDatabase, childUpdates)
});
}