Rxjava2阻止订阅与订阅

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Rxjava2阻止订阅与订阅，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1270字，纯文字阅读大概需要2分钟。

内容图文

我已经阅读了有关blockingSubscribe()和subscribe()的解释,但是我既无法编写代码,也没有找到示例来查看它们之间的区别.看来这两种方式都是相同的.有人可以提供这两个示例,最好是用Java.

解决方法:

BlockingSubscribe阻止当前线程并在该线程上处理incomnig事件.您可以通过运行一些异步源看到这一点：

System.out.println("Before blockingSubscribe");
System.out.println("Before Thread: " + Thread.currentThread());

Observable.interval(1, TimeUnit.SECONDS)
.take(5)
.blockingSubscribe(t -> {
     System.out.println("Thread: " + Thread.currentThread());
     System.out.println("Value:  " + t);
});

System.out.println("After blockingSubscribe");
System.out.println("After Thread: " + Thread.currentThread());

没有任何限制,并且可以在任意线程上运行：

System.out.println("Before subscribe");
System.out.println("Before Thread: " + Thread.currentThread());

Observable.timer(1, TimeUnit.SECONDS, Schedulers.io())
.concatWith(Observable.timer(1, TimeUnit.SECONDS, Schedulers.single()))
.subscribe(t -> {
     System.out.println("Thread: " + Thread.currentThread());
     System.out.println("Value:  " + t);
});


System.out.println("After subscribe");
System.out.println("After Thread: " + Thread.currentThread());

// RxJava uses daemon threads, without this, the app would quit immediately
Thread.sleep(3000);

System.out.println("Done");

内容总结

以上是互联网集市为您收集整理的Rxjava2阻止订阅与订阅全部内容，希望文章能够帮你解决Rxjava2阻止订阅与订阅所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端