我有一个这样的RxJava链： Single.timer(500, TimeUnit.MILLISECONDS) .doOnDisposeAction而不是Consumer，所以我无法访问其中先前映射的myObject。我现在要做的是在Rx链之外有一个外部可空变量来保存对象： var myObject: MyObject?dismiss() .subscribe {
浏览 13提问于2019-08-29得票数 1
回答已采纳
我在RxJava2中使用RxJava2类。 .doOnDispose({ /* do something */ })我看了RxJava 2代码，但MaybeMaybe是在doOnDispose中创建MaybePeek(而不是DoOnDisposeObserver)对象，
浏览 7提问于2017-11-09得票数 0
回答已采纳
如果我在RxJava中扩展了一个RxJava，我可以覆盖OnDispose()，并执行清理，比如为垃圾收集器清除一些东西。每当释放对此OnDispose()的任何订阅时，都会调用Observable<>。我知道channel.close()，但这是不一样的。有什么方法可以传播
频道<e
浏览 1提问于2019-07-16得票数 1
1回答
我使用Rx Java2已经有一段时间了，但最近遇到了一个让我感到困惑的情况。我有一个半复杂的操作链，并希望向下传递一个"state对象“。 ? 有4个操作，在此期间，我希望重复操作2和3(顺序，而不是一起)，直到某些条件为真。我知道我可以通过使用andThen()链接每个操作来解决这个问题，但这限制了我在链中传递状态对象而不到达链
浏览 13提问于2019-02-07得票数 0
2回答
让我们假设我对Android有以下情况：
webService.requestGroups我对视图对象有两个调用，每个调用都必须在主线程上执行。以及对webService的两个调用，必须在后台线程上执行。这段代码的问题是:第一次对视图的</e
浏览 4提问于2017-09-06得票数 14
我有时会使用RxJava来编写一种更具函数式的风格来处理一些复杂的过滤、映射等等(我知道这不是它的目标，我很乐意使用Kotlin或Java8来实现这一点，但我不能(我使用的是Android，所以坚持使用但是，当您试图从可观察对象中“提取”实际对象时，您总是需要编写.toList().toBlocking().singe()final List<CashRegister.map(CashRegister::g
浏览 3提问于2016-08-19得票数 1
回答已采纳
1回答
我正在实现Observable，它应该只是从网络下载一个分成多个部分的文件。下面是我的实现 subscriber.onComplete(); }在我的代码中，我创建了这个类的一个实
浏览 4提问于2017-11-29得票数 0
我对RxSwift还比较陌生，但我期待着在我的项目中更多地使用它，我希望听到一些关于我刚刚编写的操作员的反馈。我所缺少的功能是一个已弹出的缓冲区:一个与debounce操作符完全相同的缓冲区，但它不是只发出最新的值，而是发出自上次发射以来收集的所有值。在RxJava中，通过使用另一个可观察到的作为“关闭选择器”
浏览 3提问于2016-10-08得票数 3
如果用户输入了某些内容，则会出现另一个对话框，以确认前面的操作。
PublishSubject<String> inputSubject = ...;PublishSubject<Integer>
浏览 2提问于2017-09-07得票数 1
3回答
RxJava:链接可观察对象
、、、、
是否可以使用RxJava实现类似next chaining的功能： .then( (someData) -> { //do something我发现这个库非常有趣，但不知道如何将请求链接在彼此依赖于以前的地方
浏览 3提问于2014-11-15得票数 43
回答已采纳
1回答
，我不希望客户端在等待它时阻塞它。Widget>> getMatchingWidgets(WidgetCriteria c)void forEachMatchingWidget(WidgetCriteria c, Consumer<Wid
浏览 1提问于2017-10-19得票数 5
回答已采纳
2回答
嗨，我发现一些手册状态:默认情况下，Rx是单线程的.。我试着玩了一下，实际上是多线程的。下面是我尝试过的简单代码： values1+ e),
浏览 1提问于2018-02-23得票数 0
嗨，我正在阅读rxjava2，它基本上是用于异步操作的。我发现它有一个运营商的概念，而AsyncTask在安卓系统中却没有。
否则rxjava2和AsyncTask有什么区别？
浏览 1提问于2017-10-23得票数 7
回答已采纳
1回答
我想要的第一个事件是在用户登录后，创建一个粘性事件，以便每个屏幕都可以随时访问登录信息。根据mosby自己的BaseFragment类，我这样做： }
* Inject dependencies protected void inject() {
这意味着注入是在视图创建之前到达<
浏览 0提问于2016-11-16得票数 1
我需要一个功能，允许异步地将消息推送到我的PublishSubject，并以一定的速度(实际上是一个接一个地)通过ConnectableObservable处理它们。不幸的是，对onNext的PublishSubject调用似乎是在底层Subscriber处理消息后才释放的。处理每条消息需要几秒钟时间，在调试模式下，我看到在调用将消息从堆栈中推送到PublishSubject的方法之前执行<
浏览 0提问于2018-07-03得票数 0
回答已采纳
我有一个简单的用例:在远程源中查找一本书，如果它不存在，就创建它。因此，这是我过去使用rxJava1的方法： getBookById(id)
.flatMap(new Func1对于rxJava 1，我可以将null作为值传递给Observable.just (或其他辅助程序)，然后在map或flatMap运算符中检查我得到的值是null (意
浏览 1提问于2017-07-10得票数 0
回答已采纳
1回答
我有以下一组RxJava操作符： .onErrorReturnuserToken); .toBlocking()这里的问题是，doOnNext()调用和map()调用可以在空输入上操作。我可以在
浏览 0提问于2015-12-03得票数 1
回答已采纳
2回答
我用的是Rxjava和Retrofit。我知道如何使用它，但我仍然不清楚“Rxjava对Retrofit到底做了什么”。我们对REST调用使用任何转换器(如Gson)和Okhttp库进行改造，一旦得到响应，它就具有可观察的类型(如果使用Rxjava，否则它将是调用类型)。到目前为止，通过查看代码，Rxjava首先采用了可观测响应，然后使用操作符对进行了一些操作，已经得到了响应，然后它只将最后
浏览 0提问于2017-09-11得票数 0
回答已采纳
1回答
服务中的RxJava
、、、、
在我的应用程序中，我使用RxJava 1.1.6和Retrofit 2.1.0进行网络呼叫。我需要实现离线模式-同步我的应用程序中的所有数据与后端的数据。我尝试使用服务+ RxJava，但是我遇到了一些问题--我想从我的RxJava链发送一些通知，但是看起来我做不到。这个链似乎在不同的线程中执行</em
浏览 0提问于2017-12-07得票数 0
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
