我有一个可观察到的列表，它们是从特定点请求google距离和持续时间信息的。我试图仅在获取所有这些信息时加载我的屏幕，但我的subscribe on next中的这些可观察对象从未被调用( "observer.onNext(viewModel)“行被调用，并且已经获取了信息，只有我怎么能等到这些观察点完成呢？return Disposables.create() }
return observable
浏览 28提问于2019-04-22得票数 1
回答已采纳
3回答
return networkService .map { $0.a }} .flatMap { }然后，这将同时向service发送多个请求我想让流等待，直到每个请求完成。使用</e
浏览 6提问于2017-05-04得票数 4
回答已采纳
我正在使用这个领域作为后端。使用RxSwift，我为某些列提供了一个可观察到的DB表(它跟踪待定状态)。在获得事件后，我切换到另一个schedular，将列的值设置为flatMap块中的进步状态(返回可完成的)。现在，我的问题是在DB中发生太多事件时，我的可观察到的触发器会多次触发，并且不会等待我的flatMa
浏览 4提问于2020-09-03得票数 1
回答已采纳
我正在尝试创建一个轮询网络服务的流。目前，它查询服务，然后在短时间延迟后完成。我希望继续的流重新启动，而不是完成，从而永远轮询服务。但是repeat in RxSwift实际上是repeatElement，因此实际上生成了一个可观察的流。您可能会将这些concatMap转换成扁平的串行序列，但是RxSwift没有concatMap操作符。
那么，如何在RxSwift</e
浏览 8提问于2017-02-08得票数 5
我正在使用一个iOS应用程序中的系统，它实现了基于队列的负载均衡体系结构，以处理来自其他用户的多个传入通知(被处理/解释为请求)。requests") sleep(3)}
除了对队列进行一段时间(True)的检查之外，还有什么更好的方法来监听传入请求的
浏览 1提问于2018-04-10得票数 0
1回答
有谁能告诉我，是否有可能在concat操作符中创建一个可延迟完成的操作。直到现在，我使用了flatMap操作符的可观测值。SessionAPI.post(email: email, password: password)
.flatMa
浏览 2提问于2020-02-02得票数 1
我是rxswift的新手，我的问题是：现在这个observable映射到返回observable的函数：编辑:基本上我想实现动作的顺序执行。do3等待do2结果，do2等待do1结果。E
浏览 2提问于2018-03-19得票数 0
我试图按顺序执行几个操作，使用RxSwift，并且不确定如何使它工作。func doSomething(with value: SomeType) -> Single<SomeType> {
浏览 0提问于2017-05-28得票数 8
回答已采纳
1回答
然而，帖子请求被发送了两次，我没有使用Cors，所以我假设这不可能是预先准备好的请求？Profile.component.ts ngoninit似乎运行了两次，因为我首先使用正确的id接收coinId，然后是未定义的coinId。
浏览 4提问于2017-12-06得票数 0
我有一个rest控制器，它接受post请求并返回操作是否成功的状态。它可以工作100个请求每秒，因为我有多个操作在它的基础上，在最后发送响应。可能有数百个用户试图向控制器发送请求，因此所有这些都是使用可完成的未来和http异步调用程序完成的。如果每秒有1000个请求，然后控制器线程就会耗尽，因为已经有多个线程处理多个请求
浏览 0提问于2018-12-27得票数 3
我有几个可观察到的请求。每个可观察到的请求都是递归调用，当没有更多的数据时，它将调用空。recursive observable callrequest3 = recursive observable callforJoin(request, request2, request3).subscribe();
当其中的任何人完
浏览 0提问于2018-09-26得票数 2
**中观察到对 ViewModel 值的更改(**RxSwift** ViewController**？**中的**ViewModel类)
因此，如果我在Variable<..>中的任何ViewModel值在ViewModel发生的事情中发生了变化，那么ViewController就会被注意到“嘿！ViewModel中的一个或多个Variable<..>改变了！向ViewModel询问更新UI和更新UI所需的数
浏览 0提问于2018-11-26得票数 1
背景：现在这是一个非常普遍的风险，我们使用所有的第三方框
浏览 3提问于2017-11-16得票数 3
回答已采纳
1回答
我目前在使用RxSwift可观测值时执行多个网络请求时遇到了问题。我知道，如果一个人创造了一个冷的可观测的，并且它有多个观察者，可观察者将在每次被订阅时执行它的块。我尝试创建一个可观察到的共享订阅，只执行一次网络请求，并且会通知多个订阅者结果。下面是我尝试过的。事件序列
在视图模型上创
浏览 4提问于2017-01-16得票数 4
回答已采纳
我试图使用ReactiveX (RxSwift)将多张照片上传到服务器，收集来自每个请求的响应，然后发出最后一个请求来完成提交。func getPhotoDataObservable(资产: PHAsset) ->可观察到{返回创建{
浏览 2提问于2015-12-14得票数 4
回答已采纳
2回答
一旦设置了头(或未设置)，我希望发出一个http请求并返回可观察到的结果：if (useHeaders) {}
本质上，我希望等待startObs完成，然后返回可观察到的<
浏览 4提问于2017-05-30得票数 1
我们有一个使用NioServerSocketChannel和HttpServerCodec的Netty服务器。我们观察到一个坏的客户端在不等待响应的情况下在同一个TCP连接(same Channel & ChannelPipeline)上发送多个请求。这个坏客户端可以使用Netty client重新创建，并在最后使用ctx.flush()执行多个ctx.write()，以便一次发送所有<em
浏览 34提问于2021-11-02得票数 0
我有一个Thing对象数组，我想使用一个返回Observable<ConvertedThing>的异步函数将其转换为ConvertedThing对象。我想创建一个Observable<[ConvertedThing]>，它在所有转换完成时发出一个值。
如何才能做到这一点？任何帮助都非常感谢！
浏览 1提问于2016-02-05得票数 37
回答已采纳
我使用RXSwift来处理很多异步AVAssetWriterInput写入操作，但是我需要等待isReadyForMoreMediaData才能在文件中编写更多的缓冲区，如何处理呢？基本上，可观察到的程序接收了大量由asyncWriterSubject发出的缓冲区，我想按照我接收到的顺序来编写它们。private var asyncWriter = ReplaySubject<(AVAssetWriterInput,CMSampleBuffer)
浏览 10提问于2022-06-22得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
