reactivex 相关问题

ReactiveX是一个库,用于通过使用可观察序列来编写异步和基于事件的程序。

我们什么时候应该使用Combine的多播autoconnect()

我有这个代码 进口基金会 进口联合收割机 让upstreamPublisher = Just(“你好,世界!”) 让sharedSubject = CurrentValueSubject(“初始值”) //

回答 1 投票 0

为什么 Observable.Do 会抛出 InvalidOperationException“序列不包含元素”

我确实在下面的代码中得到了一个(恕我直言)意外的异常InvalidOperationException“序列不包含元素”,我认为情况不应该如此。请看代码,

回答 1 投票 0

使用 RxSwift 观察 UITextField.editing

我想观察属性UITextfield.editing。我正在使用这段代码: self.money.rx_observe(Bool.self, "编辑").subscribeNext { (值) in 打印(””) }.addDisposableTo(disposeBag) 但在...

回答 4 投票 0

RxJS 检测 observable 何时被订阅

我需要检测何时订阅了一个可观察量(observedEvents),然后订阅另一个可观察量(triggerEvent)。我不想手动订阅triggerEvent,但是...

回答 3 投票 0

重试单机未在服务器上命中

返回 Single.fromFuture( asyncStub.withDeadlineAfter(ClientConfiguration.INSTANCE.getMaxTimeout(), TimeUnit.SECONDS).checkBalance(payload)) .doOnSubscribe(s -> System.out.println(&

回答 1 投票 0

什么会导致BehaviorSubject报告另一个不相关的可观察量的未处理异常?

上下文 我正在调查一个复杂的问题,由于某种原因,BehaviorSubject 向观察者发出错误。 即使没有人真正与该可观察的交互,这种情况也会发生。 唯一的

回答 1 投票 0

RxJS AJAX 检测请求是从progressSubscriber 完成的(无论是成功还是错误)

我对 RxJS 很陌生,我有一个关于 RxJS ajax 请求的问题。我需要将progressSubscriber实现到RxJS的AjaxRequest(因为我需要进度条显示从0%到100%)。

回答 2 投票 0

ReactiveX - 像带有触发器的 Buffer 一样可观察,但只记住最后一个值

在 C# 中,使用 Rx.net 我有一个源 observable,以及另一个充当触发器的 observable。我正在寻找一个运算符,只要它

回答 1 投票 0

我需要帮助使用 Rx 创建滑动窗口速率限制器

使用Rx可以实现在指定时间内只能处理指定数量的速率限制器吗? 例如,如果您将其设置为每秒仅处理 5 次,输入如下...

回答 1 投票 0

我应该如何使用 Rx + DynamicData 定期检查许多在线服务的更新?

我有一个基本的日历/议程应用程序,它将列出一系列帐户和日历中的最新事件。例如,假设我有 3 个帐户:两个不同的 Microsoft 帐户和一个

回答 2 投票 0

RxJS 中审计和反跳的区别?

我正在阅读 RxJS 的官方文档,然后我意识到它们都在做完全相同的事情。 对我来说,它们看起来完全相似。 请指出它们之间的区别,如果...

回答 3 投票 0

如何让可观察间隔立即开始而不延迟?

我希望我的可观察对象立即触发,并且每秒再次触发。间隔不会立即触发。我发现这个问题建议使用 startWith,它会立即触发,但我然后......

回答 4 投票 0

Reactivex 中数组的概念

嗨,我开始使用 ReactiveX c#,一切听起来都不错,除了一个概念。 我不知道如何制作反应数组(或集合或列表) 我想要像 ObservableCollection 这样的东西,但是......

回答 1 投票 0

对抛出错误的自定义观察者应用 retryWhen,不起作用

我正在使用这个自定义类以 reactivex 方式连接到 MongoDB: 函数 RxMongodb(驱动程序){ 司机==空? this.driver = require('mongodb').MongoClient : this.driver = driver.MongoClient...

回答 1 投票 0

RxCpp经常调用复制构造函数。

我试图在我的程序中加入RxCpp,我注意到,框架经常调用发射对象的复制构造函数。#include #include 类...

回答 1 投票 1

observable.observationOn()和公共资源的并发问题

我在一个函数里面有一个observable。函数发生在某个队列中,即queueA,observable用observableOn(schedulerB)来订阅。在onNext中,我正在改变一个类变量。在......中,我在改变一个类变量。

回答 1 投票 2

在RxAndroidBle中,如何从Observable.comboLatest()中返回ObservableSource<out TypeVariable<R>!>!而不是Unit?

我试图从设备信息服务中获取特定设备的所有特性。我可以选择任何一个设备,然后用以下方法获取它的特性:......。

回答 1 投票 0

如何发出订阅的结果

我有以下情况。我使用RxKotlin扩展来检测我的活动按钮中的点击 我使用Room来在数据库中插入记录 这是相关的代码...。

回答 1 投票 1

我想 "插入记录到房间数据库" -> "Api调用" -> "更新本地记录"

我是一个新的rxjava android。我想在本地房间数据库中插入记录。我设置了自动生成true,所以它会为我生成id。然后我想进行api调用,将该记录发送到服务器。在我...

回答 1 投票 0

RxSwift使可观察触发对象

我有一个BehaviorSubject,通过RxDataSources绑定了我的表视图。除此之外,我还需要刷新,以创建一个可观察的对象来更新数据并更新...

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.