假设我有这样的活动:
public class TestActivity extends AppCompatActivity {
@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
final TextView countdown = new TextView(this);
setContentView(countdown);
ViewModelProviders.of(this)
.get(TestViewModel.class)
.getCountdown()
.observe(this, countdown::setText);
}
}
视图模型是:
class TestViewModel extends ViewModel {
private final LiveData<String> countdown =
LiveDataReactiveStreams.fromPublisher(
Flowable.concat(
Flowable.just("Falcon Heavy rocket will launch in..."),
Flowable.intervalRange(0, 10, 3, 1, TimeUnit.SECONDS)
.map(x -> String.valueOf(10 - x)),
Flowable.timer(1, TimeUnit.SECONDS)
.map(ignored -> "Lift off!")
)
);
LiveData<String> getCountdown() {
return countdown;
}
}
我想正确处理旋转,所以如果用户在倒计时为 5 时旋转他的设备,我希望旋转后的下一个值是 5(或者如果第二个已经过去,则为 4),只需在倒计时实际应该是的地方拿起.
如果火箭已经升空,我希望它在旋转后保持这种状态,我不希望倒计时再次开始。
目前,LiveDataReactiveStreams
在暂停时取消订阅并在恢复时进行新订阅,因此倒计时重新开始。
我猜我应该在我的 RxJava 部分代码中更改一些内容以使其正常工作。关于改变什么的任何想法?