我开始将 RxJava 与SqlBrite结合使用，但操作员遇到了一些问题zip。
假设我有 2 个课程，User并且Tweet.
public class User {
public long id;
public List<Tweet> users;
...
}
public class Tweet {
public long id;
public User poster;
...
}
以及他们各自的 SQLite 表：
user
---------
id INTEGER PRIMARY KEY
tweet
---------
id INTEGER PRIMARY KEY
poster_id INTEGER
FOREIGN KEY(poster_id) REFERENCES user(id)
和他们各自的 SqlBrite DAO
用户道：
public class UserDao {
private final BriteDatabase briteDb;
private final TweetDAO tweetDao;
...
public Observable<List<User>> getUsersWithTheirTweets() {
Observable<User> usersObs = briteDb.createQuery("user", "SELECT * FROM user")
.map(new Func1<SqlBrite.Query, List<User>>() {
@Override
public List<User> call(SqlBrite.Query query) {
Cursor cursor = query.run();
List<User> result = new ArrayList<>(cursor.getCount());
while (cursor.moveToNext()) {
User user = UserTable.parseCursor(cursor);
result.add(user);
}
cursor.close();
return result;
}
})
// transform Observable<List<User>> into Observable<User>
.flatMap(new Func1<List<User>, Observable<User>>() {
@Override
public Observable<User> call(List<User> users) {
return Observable.from(users);
}
});
// combine each user with his tweets
return Observable.zip(usersObs, usersObs.flatMap(new Func1<User, Observable<List<Tweet>>>() {
@Override
public Observable<List<Tweet>> call(User user) {
return tweetDao.getTweetsByUser(user);
}
}), new Func2<User, List<Tweet>, User>() {
@Override
public User call(User user, List<Tweet> tweets) {
user.tweets = tweets;
return user;
}
}).toList();
}
}
TweetDAO：
public class TweetDAO {
private final BriteDatabase briteDb;
...
public Observable<List<Tweet>> getTweetsForUser(final User user) {
briteDb.createQuery("tweet", "SELECT * FROM tweet WHERE poster_id = ?", Long.toString(user.id))
.map(new Func1<SqlBrite.Query, List<User>>() {
@Override
public List<Tweet> call(SqlBrite.Query query) {
Cursor cursor = query.run();
List<Tweet> result = new ArrayList<>(cursor.getCount());
while (cursor.moveToNext()) {
Tweet tweet = TweetTable.parseCursor(cursor);
tweet.user = user;
result.add(tweet);
}
cursor.close();
return result;
}
})
}
}
正如您在 中看到的UserDao，我尝试使用zip和flatMap运算符的组合来填充Tweetfor each的列表User。
第一个问题：有没有更好的方法来做到这一点？
第二个问题：那个zip操作符似乎永远挂起并且永远不会完成......我看到它被tweetDao.getTweetsByUser(user)调用但从未被调用......有人知道为什么吗？Funczip
第三个问题：有没有比使用and组合更好的方法将 an 转换Observable<List<T>>为other ？Observable<T>flatMapfrom
该死，RxJava 很强大，但学习曲线非常陡峭......