RxSwift的目的是简化异步操作和事件/数据流的组合。仅将此标记用于特定于RxSwift - Reactive Programming范例的问题，或者需要使用该语言代码的问题。使用相关标签[ios]，[osx]，[apple-watch]，[cocoa-touch]和[cocoa]来获取有关平台或框架的（语言无关）问题。
我想使以下函数成为反应性函数，函数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 {...
实例方法'flatMap'要求'String'符合'ObservableConvertibleType'
我低于RxSwift的构建错误，函数为testFlatMap（）{ > 这是问题： subject.flatMap({ (value) -> String in PublishSubject.just(value) }) 在第一行中，您告诉编译器闭包返回一个String，但是flatMap要求闭包返回一个Observable类型。 此外，仅供参考：a.flatMap { .just($0) }实际上是禁止操作。换句话说：a≣a.flatMap { .just($0) }
RxSwift-使用转换函数内部的函数构造Observable
这是我的代码段：打开类SomeClass {让驱动程序：Driver init（input：Observable ）{driver = input .map（{s-> Bool in self.convert（text：s）}）// // ...
有人可以告诉我是否可以在concat运算符中创建一个递归补全。我想获取一个会话，并在此之后加载具有相应会话ID的用户。 SessionAPI ....