reactivex 相关问题

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

停止加载订阅

如果必须加重负载,最好的方法是什么。我有以下几点。 loadProducts(){this.subscription = this._productService.getAll().subscribe(products => {this ....

回答 2 投票 0

将订阅中的加载设置为false

如果我必须取消加载,最好的方法是什么。我有以下几点。 loadProducts(){this.subscription = this._productService.getAll().subscribe(products => {this ....

回答 2 投票 0

带有和不带有ObserveOn的RxJava PublishSubject

我有三个整数观察者,如下所示:第一观察者:私有观察者 getFirstObserver(){返回新的观察者 (){@Override ...

回答 1 投票 1

io.reactivex-> android.os.NetworkOnMainThreadException

Android Studio 3.6在我的活动中:私人乐趣update(force:Boolean = false){if(!force){)} else {kycStateRepository.update()} ...

回答 1 投票 0

如何正确处理subcribe()方法?

我一直在我的代码中遇到subscribe()方法的问题(下面是调试控制台的消息)io.reactivex.exceptions.OnErrorNotImplementedException:由于遗漏而未处理该异常...

回答 1 投票 0

在RxSwift中测试UITableView.rx.itemSelected回调

我有一个绑定到实例var myStrings:BehaviorRelay的tableView,这样tableView中每个单元格的标签都设置为myStrings中每个字符串的值:myStrings.bind(...

回答 1 投票 0

以无响应方式从mongodb集合中查询所有文档的最佳方法,没有溢出RAM

我想以被动方式查询集合中的所有文档。 mongodb nodejs驱动程序的collection.find()方法返回一个游标,该游标将触发在...

回答 2 投票 3

RxJS地图运算符与解构性能

就Rxjs而言,我个人认为#2不良做法-是吗?就性能而言,以下哪种方式更可取,为什么? source $ .pipe(map(s => s.someKey)).subscribe(...

回答 1 投票 0

单个可观察对象是否提供API来设置计时器和间隔?

我一直在使用RxJava的Single Observable进行网络任务。我已经看到Observable类型提供了用于设置计时器和间隔的API,如以下示例所示。 Observable.interval(0,2,...

回答 1 投票 0

等待mergeMap中的所有可观察对象在发出自定义值之前完成

我想使用flatMap同时处理可观察对象列表,然后在处理所有内部可观察对象时发出一个空值。是否有一种优雅的方法来实现这一目标,即使用...

回答 2 投票 1

等待第一个可观察完成的最差的方法来执行第二个订阅逻辑?

我想知道实现这一目标的最佳方法。如果我有两个可观察的A和B,并且我想在A完成他的下一个逻辑之后再处理下一个B逻辑。我目前正在使用CombineLatest ...

回答 1 投票 0

[在C#中的构造函数中启动异步方法

我想知道以下列方式在构造函数中调用异步方法是否安全:可以说我们有一个异步方法Refresh,它可以从Internet上获取数据。我们也在使用反应式...

回答 1 投票 0

为什么UIView的可观察框架在订阅后仅触发一次

我正在使用RxSwift观察一个UIView的框架。这是我在视图中的代码self.rx.observe(CGRect.self,#keyPath(UIView.frame)).subscribe(onNext:{print中的frame(“ Got new frame \(...

回答 1 投票 1

RxJS中的等待语句的执行

我有以下语句:等待(client.list()的常量blob){console.log('\ t',blob.name); } client.list()返回一个异步可迭代的迭代器,并期望将其用于......>

回答 1 投票 0

RxJava2中的条件过滤器

[我有一个带有签名的方法void supplyData(String query,Integer skip,Integer count)通常,我会像这样对方法主体进行建模:MyProvider.observable(query).skip(skip).take(...

回答 1 投票 0

是否需要处置SingleObserver?如果是,在哪里?

我有以下一段代码Single.just(settings.toString()).observeOn(AndroidSchedulers.mainThread()).subscribe(new SingleObserver (){private Disposable一次性; ...

回答 1 投票 0

ReactiveX(rx)-将可观察对象应用于对象,而不是在可观察对象内部创建对象

所以我已经尝试将ReactiveX理解为一个库了一段时间了,我相信我已经开始掌握基本原理了,但是,有一个问题我找不到解决方案.. 。

回答 1 投票 0

我需要取消订阅已完成的流的订阅吗?

我已经看到了不同的来源,似乎在此问题上存在矛盾,或者也许有些我不了解。例如,我可以从异步请求中获取一个流,该请求返回一个Promise,然后...

回答 1 投票 0

RxJava2中Observer与DisposableObserver之间的差异

我知道DisposableObserver已经实现了Observer和Disposable。将onSubscribe()方法标记为final,并提供onStart()代替它。但是我不明白...

回答 1 投票 1

Flowable.compose()转变为单次或可能

是否有任何RxJava2运营商可以从可流动的应用转换为单或可能?我的意思是Flowable.compose()经营者申请一个变压器可流动并返回另一个流动的。 ...

回答 1 投票 0

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