ReactiveX是一个库，用于通过使用可观察序列来编写异步和基于事件的程序。
我想从一个树创建一个可观察的。每个节点将产生可观察到的，其依赖于可观察到它的父（例如经由switchMap）。在树的每个层面上，可观察每个...
因为如果一个新的项目进来switchMap可以切断（退订）内可观察到，我们预计以下内容：从常量项=（[1,2]）常量看出= [] const的衍生= items.pipe（...
我想几个Obserables合并成一个。我用Observable.mergeWith（）方法。我的要求是要在循环中合并。问题是没有排放的订阅发送。问题 ...
来自ReactiveX介绍页面：它有时被称为“功能反应式编程”，但这是用词不当。 ReactiveX可能是功能性的，它可能是反应性的，但“功能反应性...
我正在为我的应用程序制作启动画面。我希望它在进入主屏幕之前至少持续N秒。我有一个Rx变量myObservable，它从服务器或我的本地返回数据...
StackOverflow上有很多关于使用ReactiveX以及是否使用Subjects的问题。大多数问题最终都被人们回答起来......
extension Observable {func dispatchAsyncMainScheduler（） - > Observable {return self.observeOn（backgroundScheduler）.observeOn（MainScheduler.instance）}}我发现了这个......
我正在使用ReactiveX 1（无法迁移到版本2）。这只是问题的一个例子，但是我想要使用反应式存储库来保存实体。它返回一个可观察到的saveResult，它是......
所以我使用带有Rx的MVVM模式，就是当我运行假设在后台线程中运行我的UI线程被阻塞的操作时，这是我的viewmodel：class dataViewModel（...
我在Completable上使用retryWhen运算符，有没有办法告诉它从重试Flowable完成？像这样的东西 - PublishSubject>重试Subject = PublishSubject.create（）...
RxSwift RetryWhen导致Reentrancy Anomaly
我一直在尝试测试重试当RxSwift上的操作符和我遇到了Reentrancy Anomaly问题时，这里是代码：Observable .create {observer in observer.onNext（1）...
是否有一个Observable的首选类型，在Next事件中不需要值？
我有一个Observable，它只用于触发flatMap / map。所以我只需要Next事件而不需要值。我可以用我自己的概念来获得这样的垃圾价值，但我想知道是否......
完成后n秒重复请求（Angular2 - http.get）
我玩了angular2并且在一段时间后卡住了。使用http.get可以很好地处理单个请求，但是我想在修补一段时间并且阅读后每隔4秒轮询一次实时数据...
一般的设计问题可以描述为：我有一个websocket连接，它具有严格的生命周期 - 它需要连接和断开连接才能被正确调用，并且，因为它说...
错误：更改compilesdk后包rx.android.schedulers不存在
嗨，我更新了我的gradle和android工作室，从那时起我开始出现构建错误。一旦我将compileSdkVersion更改为28，我就开始收到错误：包rx.android.schedulers不存在...
我有一个Flowable，它发出需要由昂贵的操作处理的事件，这些操作需要元素数组：Flowable src void expensiveOp（List 批次）除了使用...
从带有DynamicData的api到ObservableCache的数据，定期更新
例如，我有api获取Items列表：Task > GetItemsAsync（）;我想使用带有ObservableCache的Items 。所以，我创建了IItemsService：...
我有一个动态数组结构。具体来说，它是谷歌地图的MVCArray。这个结构有定期的put，get，remove方法，以及一个addListener来监听任何变化。图书馆方法（......
我正在尝试将我的FRP理解从ReactiveCocoa 2.5迁移到RxSwift，我有一个误解。在ReactiveCocoa中，当我想观察一个...的调用时，我使用了rac_signalForSelector。
无法解析方法'sumDouble（io.reactivex.Observable ）”
在活动中：Double price = o.getDouble（“totalprice”）;可观察 floatObservable = Observable.just（price）; MathObservable .sumDouble（floatObservable）.subscribe（new ...