java-恢复可流动性,在屏幕旋转后转换为实时数据

概述假设我有这样的活动：publicclassTestActivityextendsAppCompatActivity{@OverridepublicvoidonCreate(@NullableBundlesavedInstanceState){super.onCreate(savedInstanceState);finalTextViewcountdown=newTextView(this);

假设我有这样的活动：

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部分中进行一些更改才能使其正常工作.有什么想法要改变吗？

解决方法:

感谢Svyatoslav Lebeckiy在Android United Slack channel时向我指出了BehaviorSubject和BehaviorProcessor并提出了解决此问题的想法.

我将视图模型更改为：

class Testviewmodel extends viewmodel {    private liveData<String> countdown;    liveData<String> getCountdown() {        if (countdown == null) {            countdown = liveDataReactiveStreams.frompublisher(startCountdown());        }        return countdown;    }    private static Flowable<String> startCountdown() {        final BehaviorProcessor<String> processor = BehaviorProcessor.create();        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!")        ).subscribe(processor);        return processor;    }}

这样,我只能在getCountdown中启动一次倒计时,而在startCountdown中创建的BehaviorProcessor负责将最后一个随后发出的值传递给其订户(在这种情况下为liveData).

由于liveDataReactiveStreams需要Flowable,因此在此处使用BehaviorProcessor代替BehaviorSubject十分方便.

总结

以上是内存溢出为你收集整理的java-恢复可流动性,在屏幕旋转后转换为实时数据全部内容，希望文章能够帮你解决java-恢复可流动性,在屏幕旋转后转换为实时数据所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。