RxSwift的目的是简化异步操作和事件/数据流的组合。仅将此标记用于特定于RxSwift - Reactive Programming范例的问题，或者需要使用该语言代码的问题。使用相关标签[ios]，[osx]，[apple-watch]，[cocoa-touch]和[cocoa]来获取有关平台或框架的（语言无关）问题。
为使用URLSession和RxSwift的函数编写单元测试
我有一个创建并返回Observable的函数，该函数使用URLSession下载和解码数据。我想为此功能编写单元测试，但不知道如何解决。函数：...
RxSwift中PublishSubject和PublishRelay有什么区别？
我是RxSwift编程的新手。编码时我对两者感到困惑。应该使用哪一个来存储表的数据源以及如何确定？
我是RxSwift的新手，正在尝试将这个框架https://github.com/rubygarage/collection-view-layouts实施到我的项目中。到目前为止，我已经知道了：扩展BaseLayout：HasDelegate {public ...
我想使以下函数成为反应性函数，函数partialRevealDrawerHeight（bottomSafeArea：CGFloat）-> CGFloat 394：457}我做了...
我想使以下函数成为反应性函数，函数partialRevealDrawerHeight（bottomSafeArea：CGFloat）-> CGFloat 394：457}我做了...
我正在尝试获取两个异步生成的可观察对象的元素，并将它们作为参数传递给函数，一旦它们都被接收到。但是，下面的ViewModel中的地图运算符未执行...
我有一个返回当前页面项目的端点。另外，如果要获取下一页的项目，则必须使用下一页的哈希值构造一个URL。此哈希作为属性返回，在...
我使用下面的代码来传递单个参数。惰性变量priceListData：Observable = {返回self.foodNamesparams1.asObservable（）.flatMapLatest（...
为什么带有多个可观察对象的RxSwift concat似乎不起作用？
我的RxSwift代码是func testOperators（）{ [ 您在concat订阅了observable2之前发出“ 3”和“ 4”。 concat尚未订阅observable2，因为它正在等待observable1完成。当concat订阅observable2时，“ 3”和“ 4”事件消失了。 作为类比：假设您有两个人扔球，而您有一个捕手。您已经告诉接球手接住第一个投手的所有球，然后切换到第二个投手。第一个投手向接球手投掷两个球，第二个投手向任何人投掷两个球，因为接球手正在等待看第一个投手是否要投出更多的球。然后第一个投手告诉接球手他已经完成了投球。接球手然后开始观看第二个掷球手，后者也说他也完成了。最后，接球手只接了两个球。 如果将observable2转换为具有足够大缓冲区的ReplaySubject，则它将重放为每个订阅者接收到的所有事件，并且您将获得所需的输出。 let bag = DisposeBag() let observable1 = PublishSubject<String>() let observable2 = PublishSubject<String>() Observable.concat([observable1, observable2]) .subscribe(onNext: { (value) in print(value) }).disposed(by: bag) observable1.on(.next("1")) observable1.on(.next("2")) observable1.on(.completed) //observable1 emission has been completed here. //so now observable2 emission will start here observable2.on(.next("3")) observable2.on(.next("4")) observable2.on(.completed) //observable2 emission has been completed here. 这将为您提供预期的输出，希望对您有所帮助：）
我有一个返回当前页面项目的端点。另外，如果要获取下一页的项目，则必须使用下一页的哈希值构造一个URL。此哈希作为属性返回，在...
我正在尝试创建一个使用RxAlamofire返回Observable的函数：class APIManager {let disposeBag = DisposeBag（）func getResponse（credentialData：...
[我试图创建使用RxAlamofire返回Observable的函数：类APIManager {let disposeBag = DisposeBag（）func getResponse（credentialData：Credentials，...
'subscribe（onNext：onError：onCompleted：onDisposed :)的调用结果未使用
我试图创建使用RxAlamofire返回Observable的函数：func getResponse（credentialData：Credentials，ulr：String）-> Observable
[背景：我的团队正在启动一个新的中等大小的Swift项目（大约20 MM），我正在考虑在RxSwift中进行开发。我的一位经理怀疑，一旦他对调试产生了不好的经验...
[我正在尝试使用RxSwift在没有RxSwift的情况下检测双击，我会这样：私人func setupFakePanView（）{let singleTapGesture = UITapGestureRecognizer（）let ...
我正在尝试弄清是否要在此处创建保留周期。我想使用以下内容将集合视图的当前偏移量绑定到UIPageControl：collectionView .rx .contentOffset ...
我的RxSwift代码是func testOperators（）{ [ 您在concat订阅了observable2之前发出“ 3”和“ 4”。 concat尚未订阅observable2，因为它正在等待observable1完成。当concat订阅observable2时，“ 3”和“ 4”事件消失了。 作为类比：假设您有两个人扔球，而您有一个捕手。您已经告诉接球手接住第一个投手的所有球，然后切换到第二个投手。第一个投手向接球手投掷两个球，第二个投手向任何人投掷两个球，因为接球手正在等待看第一个投手是否要投出更多的球。然后第一个投手告诉接球手他已经完成了投球。接球手然后开始观看第二个掷球手，后者也说他也完成了。最后，接球手只接了两个球。 如果将observable2转换为具有足够大缓冲区的ReplaySubject，则它将重放为每个订阅者接收到的所有事件，并且您将获得所需的输出。 let bag = DisposeBag() let observable1 = PublishSubject<String>() let observable2 = PublishSubject<String>() Observable.concat([observable1, observable2]) .subscribe(onNext: { (value) in print(value) }).disposed(by: bag) observable1.on(.next("1")) observable1.on(.next("2")) observable1.on(.completed) //observable1 emission has been completed here. //so now observable2 emission will start here observable2.on(.next("3")) observable2.on(.next("4")) observable2.on(.completed) //observable2 emission has been completed here. 这将为您提供预期的输出，希望对您有所帮助：）
我正在尝试绑定委托，这是完成的操作/ **委托代理** / func castOrThrow （_ resultType：T.Type，_ object：Any）抛出-> T {保护let returnValue = object as ？ T ...
如何在RxSwift中使用flatMap观察较高的Observable？
这里已解释了RxSwift的map和flatMap之间的差异。现在，我想观察内部可观察对象发生变化时的上部可观察实例。我该怎么办？让我们...
给出本文所述的设计模式，这是一个示例视图模型：最终类SayHelloViewModel：ViewModelType {let input：Input let output：Output struct Input {...