RXKOTLIN/RXJAVA:使用可观测数据的套接字之间的通信
RXKOTLIN/RXJAVA:使用可观测数据的套接字之间的通信
提问于 2021-06-13 16:52:15
我是RXKotlin/RXJava的新手。我正在开发Android的后台服务。
在我的工作中，我
- 蓝牙套接字
- TCP套接字
每当数据在蓝牙套接字上可用时，读取并写入TCP套接字。每当在TCP套接字中接收数据时，写入蓝牙套接字。
有人能帮我吗：
如何使用Observables?
- how实现
- 交换套接字id information?
- how来交换数据？谢谢
回答 1
Stack Overflow用户
回答已采纳
发布于 2021-06-14 08:16:13
请尝试使用RxSubjects (https://blog.mindorks.com/understanding-rxjava-subject-publish-replay-behavior-and-async-subject-224d663d452f)
让我以PublishSubject为例。
//a publish subject which publishes int values
public PublishSubject<Integer> source = PublishSubject.create();
source.onNext(1);
source.onNext(2);所以上面的代码行属于蓝牙套接字类。
现在，在TCP套接字类中，使用源，您可以在这里观察。
source
.subscribe(
{
//result
},
{
//error
}
)就是这样。
请确保订阅发生在蓝牙套接字开始发布数据之前。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/67960660
复制相关文章
相似问题
腾讯云开发者
