适用于Android的RxJava绑定
使用 Cucumber 和 RxJava 在 AndroidTest 中进行活动清理
我在黄瓜测试结束时观察到一个奇怪的堆栈跟踪。 我的测试基于 cucumber-jvm android 示例。我使用 RxJava2 在 @Then 方法中执行一些异步过程。没有异步进程，我...
RxJava 和 Retrofit 的自定义 onNext() 实现
我正在使用 RxJava 和 Retrofit，并且我正在尝试找到一种真正干净的方法来抽象我的 API 调用，这样我就可以最大限度地减少 Activity 中的代码。 到目前为止，我有这样的事情：
我有以下方法使用 otto 和 AsyncTask 向 UI 发布响应。 private static void onGetLatestStoryCollectionSuccess(final StoryCollection StoryCollection, Final Bus 总线) { 新
无法为 io.reactivex.Observable 创建调用适配器
我将向我的服务器（它是 Rails 应用程序）发送一个简单的 get 方法，并使用 RxJava 和 Retrofit 获取结果。我所做的事情是： 我的界面： 公共接口 ApiCall { 字符串
RxAndroidBle 在 Kotlin 中写入（不是长写入）时等待外设的响应
我正在尝试使用 RxAndroidBle 在 Android Kotlin 中写入外围设备。应用程序写入外设，如果此写入请求成功，则外设会做出响应，即 雅阁...
用 RxJava2 替换 AsyncTaskLoader 的最佳方法是什么？
我是 RxJava 的超级初级者，如果有更好的方法，我可能需要找到更好的方法。 我正在研究遗留的 Loader 代码，我想用 RxJava 替换它。我的
我刚刚开始使用 RxJava，但也许还没有点击。 1. 整数 [] 项目 = {1, 2, 3, 0, 0, 4, 5, 6, 1}; Observable.from(项目) .map(this::invert) .订阅...
RxAndroid + Retrofit callTimeout不触发onError。
我使用RxAndroid+Retrofit进行http请求。代码如下。Interceptor headerInterceptor = getHeaderInterceptor(); HttpLoggingInterceptor httpLoggingInterceptor = new ...
将现有的WebSocket实现转换为Android Java中的Reactive WebSocket。
我在Android中使用OKHttpClient与WebSockets。我想把它转换成反应式编程。如何实现这一点。现在我正在做的WebSocket连接。/ OkHttp客户端...
如何解决RxJava onSuccess()方法中的意外返回值？
我打算把我的一个方法重构为：if (!isMobileBluetoothOn()) { sendError(); return false; } to this getBluetoothState().subscribe(state>{ ...
在执行AndroidSchedulers.mainThread()时出错。
我有一个片段，我已经实现了一些代码： public void onViewCreated(@androidx.annotation.NonNull View v, @Nullable Bundle savedInstanceState) { super.onViewCreated(v, ...
在更新关于RxJava / RxAndroid进度的UI时发出单个项目
我目前正在尝试在Android中学习RxJava。我需要一些指南。此刻，我正在尝试将下面的AsyncTask重写为RxJava：公共类MyAsyncTask扩展了AsyncTask <>
我有一个值数组，需要将其发布到api链接。到目前为止，方法是遍历每个元素，然后发布。但是，我正在将代码迁移到rxJava并进行改进。我尝试过...
对这个Observable进行编码以获取位置的正确方法是什么？
我正在编写一个Observable来帮助我获取用户的国家/地区代码（然后将其传递给另一个Observable。这是我编写的代码：val tm：TelephonyManager = requireContext（）...。
RXAndroid / RXJava2：链接三个改造请求并再次重复相同的过程
我已经开始学习RxAndroid，并且已经了解了反应式编程方法以及平面图，地图和xmap等不同运算符的功能。我有以下情况，我有一个列表...
我有以下问题：我有一个Single，它返回一个对象列表，在每个对象内部，还有一个字段也是Single，并返回一个项目列表（这是我需要的），但是...
我想将company和workFor变量合并为一个流，但是我不知道如何。我尝试使用switchMap，zip，merge和concatMapIterable，但没有任何效果。还是我做错了。。我的...
我想进行应用程序范围的Internet连接监视，为此，我正在使用rxjava，我制作了一个util类，并获得了用于连接状态的静态方法，如下所示：val ConnectivityManager = ...
如何让地图等到当前索引项完成处理，然后使用RxJava处理下一个项？
我正在尝试将输入流转换为文件。因此，当用户选择1张图片时，一切正常。但是，当用户选择多个图像（例如4个）时，下面的代码将无法正常工作...
我实际上是rxjava的新手，并试图通过我的dao在returng Single的房间中使用它，但是在构建时我一直找不到符号返回RxRoom.createSingle，以下是我的dao @ ...