注意,foo(o)是在订阅lambda函数中调用的。这在Android中产生了严格的模式错误。当然,我可以在这里分拆一个线程,但这是Rxjava的方法吗?我现在需要再考虑一下线程了吗?想知道我在这里的最佳选择。我如何才能这样做RxJava方式,以便其他部分的代码可以订阅新的事件,这将返回网络呼叫响应?I don't want to just process it right here.
更新:为了澄清我想要做的
我有火,忘记了不需要很长时间的操作,但是足够长,以至于我想在后台积极地运行它们。那里的生存期基本上是在与服务器的连接存在或10秒过去的时候。我不知道如何存储它们,以便在保持正确的生命周期的同时高效地清除它们。// If I use a CompositeSubscription
subscriptions.add(fireAndForget) // how does it get removed????我可以在我的</em
我是新的单位测试,我是单位测试改造与rx android。我有一个可以观察到的,就是从api中获取访问令牌,我使用它进行修改来发送请求。由于这是我的代码,所以我得到了Null指针异常:public class AuthenticationTokenGetterTest我观察到的代码是我正在测试的: public Observable<String> ge
我有一个小小的util方法,它可以给我一个Observable来监视蓝牙状态。appContext.registerReceiver(broadcastReceiver, new IntentFilter(BluetoothAdapter.ACTION_STATE_CHANGED));}
当我在活动中使用此方法时