我目前正在学习如何使用RxJava,我希望计算从数据库中获取的数据,然后异步地计算它们,但是等待所有这些数据都被计算出来。= getDatasFromDatabase();
list.forEach(data -> compute(data)); // How can I make this async using RxJava
我有一个可观察的缓存并重用它们。它们通常都使用某种类型的缓存(主要是replay(1).refCount()),并且我确保底层计算只在这种情况下完成一次。目前,我只能这样做:o.connect() // make sure this hot observable always is connected and processes it's input
return o // this one is cac