func loadMovies() -> Observable<[Movie]> { return Observable.create{ observer -> Disposable in
obsMovies.subscribe我想知道如何在释放之前等待函数获取电影。我想在tableView中显示所有内容。我是RxSwift
浏览 17提问于2021-04-12得票数 1
回答已采纳
我是rxswift的新手，我的问题是：现在这个observable映射到返回observable的函数：
func do(action: String) -> Obs
浏览 2提问于2018-03-19得票数 0
我有一个Thing对象数组，我想使用一个返回Observable<ConvertedThing>的异步函数将其转换为ConvertedThing对象。我想创建一个Observable<[ConvertedThing]>，它在所有转换完成时发出一个值。
如何才能做到这一点？任何帮助都非常感谢！
浏览 1提问于2016-02-05得票数 37
回答已采纳
我对RxSwift还不那么信服，而且真的很难理解。在查阅了不同的材料后，我不能“继续工作和操作序列”。总的来说，我在类型转换方面有问题：我有CocoaAction处理，应该返回</
浏览 0提问于2017-08-17得票数 10
回答已采纳
1回答
带参数的链序列可观测性
、、、
我对RxSwift相当陌生，所以我有以下问题，假设我有3个可观察的示例函数，它们返回不同的可观测类型： return Observable.create { observer in
.addDisposableTo(disposeBag)
retur
浏览 3提问于2017-08-15得票数 0
回答已采纳
2回答
现在，这个实现看起来像这样： return Observable<Profile>.create { (observer}
func getFriends() -> Observable&l
浏览 0提问于2017-05-14得票数 2
1回答
我想查看这个列表，并使用另一种方法下载每个项，该方法返回/下载Observable<Item>，最终在这个函数中返回一个Observable<[Item]>。如何使用RxSwift/RxCocoa运算符来完成此操作？
浏览 2提问于2016-07-07得票数 3
回答已采纳
上下文
struct MyService {
static func fetchProducts() -> Observable<[Product]> {...}static func deleteCache() -> Observable<Void> {...}但是，使用该方法，我将失去第一个
浏览 0提问于2018-10-01得票数 1
回答已采纳
使用RxSwift 3.6.1，我对ObservableType做了这个扩展，以便在错误请求之后获得一个新的令牌： public func retryWithToken() -> Observable<E> { }}Session.share
浏览 3提问于2018-02-01得票数 4
回答已采纳
目前，它查询服务，然后在短时间延迟后完成。我希望继续的流重新启动，而不是完成，从而永远轮询服务。但是repeat in RxSwift实际上是repeatElement，因此实际上生成了一个可观察的流。您可能会将这些concatMap转换成扁平的串行序列，但是RxSwift没有concatMap操作符。
那么，如何在RxSwift中循环可观察到的内容呢？
浏览 8提问于2017-02-08得票数 5
1回答
子类RxSwift/反应扩展
、、、、
handler(potato) handler(carrot) }对于相同的函数，我还有一个反应性的版本/API： returnObservable.create { observer in
self.bas
浏览 1提问于2016-12-12得票数 4
我对RxSwift很陌生。 return str.asObservablefunc someFunc(_ str:PublishSubject<String>) -> Observable<String> {
if !isValidPassword
浏览 2提问于2022-06-29得票数 1
1回答
obsScan, obsReduce) { scan, reduce in}let obs = Observable.zip(obsScan, obsReduce, resultSelector: { (scan, reduce) -> _ in我不明白为什么我使用选项卡来使用闭包自动完成函数，而当我填充参数时，我得到了一个错误。static func zip
浏览 2提问于2017-11-18得票数 1
回答已采纳
我正在尝试使用rxSwift和Alamofire从REST (swift 2.3)获取JSON数据。这是我的代码： return ObservableonDisposed: { }onDisposed<
浏览 2提问于2016-12-30得票数 3
回答已采纳
当使用if/else根据条件返回a或b时，我得到了这个错误：Cannot convert value of type 'Observable<_.Element>' to specified type'Observable<Int>'let b = Observable.of(2)let c: Observable<Int&
浏览 27提问于2019-11-18得票数 1
回答已采纳
3回答
给定这样的服务类： let networkService = NetworkService()
.flatMap { }然后我想让流等待，直到每个请求完成。使用merge操作符可
浏览 6提问于2017-05-04得票数 4
回答已采纳
假设我有一个函数，它接受两个参数-- Observable<String?>和Observable<Person?>，并返回Observablereturn Observable.combineLatest(self.id, personStream)return updatedPerson } else { }如何在这个映射函数中返回这个更新过
浏览 11提问于2018-01-27得票数 1
回答已采纳
1回答
我试图使用MVVM模式将RxSwift添加到代码的平静中。我的应用程序需要得到FoodType (沙漠，晚餐等)的列表。一个API中的食物，并将它们保存到领域数据库中。然后，我可以看到一个UITextField和一个UIButton。
}
我想将RxSwift添加到该代码中，但是如何处理异步API。在第一次启动时，应用程序没有数据(我不想在开始时填充)，但是
浏览 0提问于2017-02-27得票数 0
回答已采纳
2回答
闭包元组参数出错
、、、、
我正在尝试使用RxSwift和RxAlamofire编写一个API层。以下是API请求的代码。, isSecondTryAfterAuth: Bool = false) -> RxSwift.Observable<(HTTPURLResponse, Any)> return RxAlamofireJSONEncoding.default, headers: self.appDelegateInstance.refreshToken)
.map({ (response, json) -> <
浏览 3提问于2018-04-18得票数 1
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
