使用RXSwift等待多个可观察到的请求完成
是一种常见的异步编程技术，它可以简化并发编程和处理多个请求的情况。下面是对这个问题的完善且全面的答案：
RXSwift是一个基于响应式编程范式的Swift框架，它提供了一种优雅的方式来处理异步事件流。在使用RXSwift等待多个可观察到的请求完成时，可以使用以下步骤：
- 创建多个可观察对象：使用RXSwift的Observable创建多个可观察对象，每个对象代表一个异步请求。这些可观察对象可以是网络请求、数据库查询、或者其他需要异步处理的任务。
- 组合可观察对象：使用RXSwift的操作符（如combineLatest、zip等）将多个可观察对象组合成一个新的可观察对象。这个新的可观察对象将在所有原始可观察对象都发出事件后才会发出事件。
- 订阅可观察对象：使用RXSwift的subscribe方法订阅新的可观察对象，以便在所有请求完成后执行相应的操作。可以通过传递闭包来处理请求完成后的逻辑，比如更新UI或者执行其他操作。
使用RXSwift等待多个可观察到的请求完成的优势在于简化了异步编程的复杂性，提供了一种声明式的方式来处理并发任务。它可以帮助开发人员更好地组织和管理多个异步请求，提高代码的可读性和可维护性。
应用场景：
- 并行请求：当需要同时发起多个请求，并在所有请求完成后进行处理时，可以使用RXSwift等待多个可观察到的请求完成。
- 多任务协调：当需要协调多个异步任务的执行顺序或者并发执行多个任务时，可以使用RXSwift等待多个可观察到的请求完成。
- 异步数据处理：当需要处理多个异步数据流，并在所有数据流都完成后进行下一步操作时，可以使用RXSwift等待多个可观察到的请求完成。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云函数（云原生）：https://cloud.tencent.com/product/scf
- 腾讯云数据库（数据库）：https://cloud.tencent.com/product/cdb
- 腾讯云CDN（网络通信）：https://cloud.tencent.com/product/cdn
- 腾讯云安全加速（网络安全）：https://cloud.tencent.com/product/ddos
- 腾讯云音视频处理（音视频）：https://cloud.tencent.com/product/mps
- 腾讯云人工智能（人工智能）：https://cloud.tencent.com/product/ai
- 腾讯云物联网（物联网）：https://cloud.tencent.com/product/iotexplorer
- 腾讯云移动开发（移动开发）：https://cloud.tencent.com/product/mobdev
- 腾讯云对象存储（存储）：https://cloud.tencent.com/product/cos
- 腾讯云区块链（区块链）：https://cloud.tencent.com/product/baas
- 腾讯云虚拟专用网络（网络通信）：https://cloud.tencent.com/product/vpc
- 腾讯云云原生容器服务（云原生）：https://cloud.tencent.com/product/tke
- 腾讯云元宇宙（元宇宙）：https://cloud.tencent.com/product/mu
相关·内容
现在，我需要基于配置API更改应用程序主题(颜色)，所以我使用RxCocoa，RxSwift框架在每个视图控制器上创建可观察到的应用程序，在应用程序上应用一个新主题。
我的问题是使用DisposeBag的最佳实践是什么：
在每个视图控制器上创建新的DisposeBag对象？
还是对所有可观测数据使用一个全局DisposeBag？
提前感谢
浏览 0提问于2018-08-05得票数 10
回答已采纳
我刚开始测试联合国RxSwift。我设法用RxBlocking测试一个可观察到的值。但是，如果一个可观察到的对象没有发送任何值，我就无法找到通过测试的语法。
我认为我应该使用toBlocking(timeout: )，但是我找不到方法(我有一个错误，它超时了，但是测试失败了)。
谢谢你的帮助
浏览 2提问于2021-03-29得票数 3
回答已采纳
2回答
我希望有一个可以观察到的，当我们还没有释放价值的时间范围内，其他的事情会发生，例如，显示一个旋转器。
因此，在我的代码示例中，我只在发出值之后引用我的视图。
observable.debounce(0.3, scheduler: MainScheduler.instance).do(onNext: { spinner in
spinner.stop() //here I set it to stop, I want to run spinner.start() while we are in the debounce area
}).subscribe().disposedBy(di
浏览 1提问于2018-10-10得票数 0
回答已采纳
我正在学习RXSwift，我对可观察性有点困惑。我理解这个理论，它可以“随着时间的推移”释放出一些事件。但是，我必须用一个值初始化它，订阅它，并使用这个值(这是没有意义的)，但是我不能在以后更改这个可观察值的值，那么，说它可以“随着时间的推移”发出值有什么意义？有人能向我澄清一下吗？非常感谢!
浏览 0提问于2019-01-28得票数 1
回答已采纳
2回答
只是继承了这个代码库，我不太熟悉RxSwift。我读了一些书，但找不到解决问题的办法。
我们有一个变量声明。这将从网络调用中保存信息，然后用于将信息加载到集合视图。因此，集合视图显示多个相似项。
var allPhotos = BehaviorRelay<[Photo]>.init(value: [])
如何将其转换为一组以删除重复项？
浏览 2提问于2020-03-24得票数 0
回答已采纳
我从一篇博文上看到了这件事。
当您订阅Observable时，Disposable保留对Observable的引用，Observable保持对Disposable的强烈引用(Rx在这里创建某种保留周期)。由于这个原因，如果用户导航回到导航堆栈中，Observable将不会被解除分配，除非您希望它被解除分配。
所以纯粹为了理解这一点，我创建了一个虚拟项目:哪里有视图，在视图的中间，有一个巨大的按钮，它会发出关于按钮被点击多少次的事件。就这么简单。
import UIKit
import RxCocoa
import RxSwift
class Button: UIButton {
浏览 1提问于2018-10-16得票数 3
我试图按顺序执行几个操作，使用RxSwift，并且不确定如何使它工作。
问题是返回一个可观察到的Single，其中成功/错误取决于Completable调用是成功还是失败。
我的代码尝试大致如下所示：
func doSomething(with value: SomeType) -> Single<SomeType> {
return repository.replace(with: value) // replace() returns a completable
.asObservable()
.flatMap { () ->
浏览 0提问于2017-05-28得票数 8
回答已采纳
1回答
API轮询和超时
、、、、
我有一个轮询用例，其中：
我想调用一个基于业务逻辑的API，返回数字(1-10)或错误( API中的网络问题/异常等)。立即(1.5秒-2秒)。
如果API返回一个错误( API中的网络问题/异常等)然后，我想取消订阅轮询和显示错误。
如果API返回成功，我希望检查返回值和取消订阅(如果返回值为5)或保持轮询进行。
我想每5秒打一次电话给API。
我希望将轮询的最大时间(超时/阈值)保持为3分钟。如果我在这3分钟内没有得到想要的响应( 5)，那么轮询就会出错。
我现在就是这样实施的：
this.trackSpoke$ = interval(5000)
浏览 1提问于2018-08-17得票数 2
我在试着弄清楚可观察到的可连接性。
如果源已终止，可连接的可观察到的onComplete 事件是否会在重放结束时传递给订阅者？
我已经看到有人说应该这样做，但在RxSwift中似乎没有这样做。这是我的错误，还是这是斯威夫特的正确行为？
let source = Observable.just(“test”).replay()
let disposable = source.subscribe(onNext:{}, onComplete:{print(“would this print?”})
浏览 3提问于2018-08-16得票数 1
3回答
我想把一个完整的东西和一个可观察的元素联系起来。在调用flatMap之后，onCompleted和onError回调似乎不会在订阅时被调用。
var user = PublishRelay<User>()
func fetchUserInformation(_ userId: String) -> Completable {
return Completable.create { observer in
apiService.fetchInformation(for: userId, completion: { response in
浏览 0提问于2018-06-08得票数 7
回答已采纳
1回答
我有许多带有结果完成处理程序的函数，我想将这些函数转换为RxSwift。
他们遵循这一公约：
func fetch(id: Int, completion: @escaping (Result<AuthorType, DataError>) -> Void) {...}
我可以用典型的：
return Observable<AuthorType>.create { on(.next... }
有没有一种更体贴的通用方法？
func fetch() -> Promise<AuthorType> {
return Promise { fetch(co
浏览 0提问于2019-08-17得票数 1
回答已采纳
我愿意重播Completable的最后一个结果，我相信完全像一样。
以下RxSwift代码输出：“已完成”
let connectable = Completable.empty().asObservable().replay(1)
connectable.subscribe(onCompleted: { print("completed") })
connectable.connect()
现在，如果我在.connect()之前.subscribe()，我什么也得不到：
let connectable = Completable.empty().asObservable().
浏览 1提问于2019-02-03得票数 2
回答已采纳
我有一个问题，不知道该怎么解决。
在我的ViewModel中，我得到了有价值的可观测字段。
self.diseaseDetails = Observable<Disease>.create { (observer) -> Disposable in
_ = SAPI.get().diseases(diseases: 5, success: { (disease) in
observer.on(.next(disease))
observer.on(.completed)
浏览 0提问于2018-10-23得票数 0
回答已采纳
假设我有两个REST端点，如下所示：
加载查找列表(例如位置)：host/api/locations
加载用户详细信息: host/api/ user /1
我将在HTML表单上显示此信息，该表单具有要加载的位置列表。加载用户详细信息时，应将默认的选定值设置为用户的归属位置，这是用户详细信息的一部分。
我知道我可以通过链接来做到这一点，要么使用订阅方法，要么使用。但它们实际上都是在第二个API调用依赖于第一个API调用的响应时使用的。在我的示例中，这两个API调用之间不存在依赖关系，唯一的问题是位置应该加载到用户的主位置，并将其设置为选定的值。
做这件事最好的方法是什么？
浏览 4提问于2020-07-03得票数 0
回答已采纳
我正在尝试下载一些json，解析它，检查json中的一些信息，取决于结果是否继续处理。
RxSwift最惯用的方法是什么？
URLSession.shared.rx
.data(request:request)
.observe(on: ConcurrentDispatchQueueScheduler(qos: .background))
.flatMap(parseJson) // into ModelObject
.flatMap(checkModel) // on some c
浏览 7提问于2021-06-09得票数 1
回答已采纳
2回答
当我在订阅之前添加toArray()时，就不会得到回调。
googleCalendarUseCase.getEventsFromCalendars(calendars: selectedCalendars).subscribe(onNext: { (event) in
print(event.summary) //print thousands of elements
}).addDisposableTo(disposeBag)
googleCalendarUseCase.getEventsFromCalendars(calendars: selecte
浏览 2提问于2016-09-28得票数 1
回答已采纳
看一下这个例子：
func query2() -> Observable<Int> {
print("query2() called")
return Observable.create { observer in
print("creating query2() thread")
let thread = Thread.init(block: {
sleep(1)
let numbers = [
1,2,3,4,5
浏览 1提问于2021-03-26得票数 1
回答已采纳
我是RxSwift的新手，我尝试的是执行以下操作，
用户类型为search UiTextField
应用程序必须在用户完成输入后等待1秒，以确保不按下每个字母、写或删除按钮的Api。
应用程序点击我的Api搜索
我尝试了下面的代码作为示例
class DestinationSearch: UIViewController {
let searchTF = UITextField()
var disposeBag = DisposeBag()
override func viewDidLoad() {
super
浏览 0提问于2021-07-28得票数 1
回答已采纳
5回答
我试图把我对玻璃钢的理解从ReactiveCocoa 2.5迁移到RxSwift，我有一个误解。在ReactiveCocoa中，当我想观察一个方法的调用时，我使用了rac_signalForSelector。有任何方法可以使用RxSwift实现这个逻辑吗？
我编写了一个小示例，在该示例中，我希望在test方法调用时释放订阅。但是在订阅块中，我仍然可以看到一个next(6)事件。我做错了什么？
let subject = PublishSubject<Int>()
subject.takeUntil(self.rx.sentMessage(#selector(test))).subs
浏览 7提问于2016-09-26得票数 4
回答已采纳
我想要一个单独的API调用文件-
APIHandler.js
const loginAPI = 'https://..../login';
export async function login(emailAddress, pass) {
const reqOptions = {
method: 'POST',
headers: {
'Accept': 'application/json',
'Content-Type': &
浏览 0提问于2018-07-28得票数 1
回答已采纳
2回答
我无法让这个解决方案起作用：
也许有人能告诉我哪里出错了。加载变量永远不会变为false。我想问题在请求中是可以观察到的，但我找不出原因。
class PaginationNetworkModel<T1: Mappable>: NSObject {
let refreshTrigger = PublishSubject<Void>()
let loadNextPageTrigger = PublishSubject<Void>()
let loading = Variable<Bool>(false)
let elements = Variab
浏览 7提问于2017-04-15得票数 4
回答已采纳
我对RxSwift很陌生。
我是否可以根据下面两个函数的条件创建一个返回可观测的函数？
func isValidPassword(_ str: PublishSubject<String>) -> Observable<Bool> {
return str.asObservable().map {
validator.isValidPasswordRegex($0) && $0.count >= 8
}
}
func isNotEmpty(_ str: PublishSubject<String&g
浏览 2提问于2022-06-29得票数 1
1回答
我是RxSwift新手，试图找出实现以下目标的最简单方法：
登录到应用程序后，第一个'getData‘请求就完成了。此数据非常重要，将被加载到一个旋转器后面。当接收到数据时，将数据保存在核心数据数据库中。当此任务完成(使用完成块)时，启动下一个请求(应该在后台异步运行)，这里的数据也保存在db中。如果访问了呈现后一个数据的视图，并且还没有接收到数据并从db获取数据，则应该显示一个自旋器。
模型
let subject = ReplaySubject<[MyObject]>.create(bufferSize: 3)
var observable : Observ
浏览 2提问于2018-04-01得票数 0
1回答
我试图在我的代码中使用RxSwift，并有一个问题：
我有一个具有不同属性的Settings类(例如，staticValue)：
类DeviceSettings: NSObject { var staticValue =变量(0)}
我有一个带有UITextField的UI，它应该是与属性双向连接的，它工作得很好：
staticValueField.rx.controlEvent(.editingDidEnd).asObservable() settings.staticValue.asObservable() .map({ String( $0 ) }) .bindTo(static
浏览 0提问于2017-05-18得票数 0
我有一个同步操作，运行在RxJS可观察订阅链的某个地方。
这种同步操作在本地存储(同步)上设置数据，而本地存储(同步)是为了执行http调用(异步/可观测)而需要的。
以下是顺序的总结：
异步操作返回可观察到的调用
同步本地存储上的操作设置数据
使用本地存储日期进行异步操作并返回可观察到的
最终订阅
在调用3.时，本地存储上似乎没有可用的数据--假定是由2.设置的。
以上只是对这个问题的简化。
这是完整的代码(在打字本中)：
这是由表单(位于组件中)调用的：
resetPassword() {
this.submitted = true;
if (t
浏览 4提问于2016-08-24得票数 1
1回答
我将的第一个示例(at )复制到main.swift中。
import Foundation
import Alamofire
Alamofire.request("https://httpbin.org/get").responseJSON { response in
print(response.request) // original URL request
print(response.response) // HTTP URL response
print(response.data) // server data
prin
浏览 5提问于2017-02-16得票数 0
回答已采纳
3回答
我正试图实现我的可观察性，只有在以前的可观测性已经完成时才能执行。我不能使用flatMap，因为订阅可以从不同的地方调用，而且这些可观察到的内容并不是相互连接的。具体来说:我的CollectionView从服务器加载更多的内容，在用户单击“发送评论”按钮2秒后，CollectionView仍在加载它的批处理。因此，我想等到CollectionView更新完成，然后执行我的评论的发布请求。我创建了一个名为ObservableQueue的类，它运行得很好。但我需要知道它是否存在内存泄漏、死锁等问题，或者我只是漏掉了什么。下面是：
extension CompositeDisposable {
浏览 0提问于2018-09-28得票数 6
回答已采纳
1回答
我可能用错了方法，但我有一个函数，我想用它来随时间发出多个值。但我不想让它开始发射，直到有东西订阅了那个对象。我是从RxSwift来组合的，所以我基本上是在尝试在RxSwift世界中复制Observable.create()。我找到的最接近的是Future a Future，但期货只会成功或失败(所以它们基本上就像RxSwift中的单个)。
我是不是遗漏了什么基本的东西？我的最终目标是创建一个函数，该函数处理视频文件并发出进度事件，直到完成，然后发出完成文件的URL。
浏览 12提问于2020-06-01得票数 0
回答已采纳
我有一个项目数组，在每个元素上，我要进行一个HTTP调用，等待它完成，然后进行另一个调用，每次只调用一个。
我试过：
index(item) {
return this.service.index(item).pipe(
map(response => {
// handle success case
}),
catchError(error => {
// handle error case
})
)
}
async processArray(array) {
const pro
浏览 0提问于2018-12-25得票数 7
回答已采纳
1回答
正如大多数人所知道的，引入了一个名为的标准化浏览器机制，它允许在浏览器确定没有网络活动的情况下，在后台预装选择URL的内容。它是通过在头部添加以下内容来使用的：
<link rel="prefetch" href="http://www.example.com/">
我很好奇这种机制是否对也有效--也就是说，如果我指定了一个链接预取，然后在这个页面的后面某个时候启动一个AJAX请求，那么XHR是一个，还是请求整个页面，实际上忽略了一个部分预加载的页面？
在英语中: AJAX请求也会受益于预加载或部分预加载的内容吗？
浏览 3提问于2015-05-06得票数 16
此如下所示：
Windows机制(例如WaitForMultipleObjects())一次只能等待64个事件对象。Winsock 2提供了WSAEventSelect()函数，它允许您使用Windows的事件机制来等待套接字上的事件。因为它使用Windows的事件机制，所以只能一次在64个套接字上等待事件。如果希望一次等待超过64个Winsock事件对象，则需要使用多个线程，每个线程等待的套接字不超过64个。
这个说法正确吗？我想监视300个套接字，看看它们是否有要读取的挂起的数据，所以我可以只创建5个线程并使用WSAEventSelect()来完成吗？
浏览 0提问于2015-02-20得票数 1
回答已采纳
1回答
这是我的代码：
if (confirm("Are you sure you want to delete the contact?")) {
this.http.delete(this.apiRoot + id)
.subscribe()
this.loadContacts()
.subscribe();
}
尝试了很多事情，但基本上我希望Web方法在调用loadContacts()之前返回
浏览 1提问于2022-11-21得票数 0
1回答
我有一个返回Single<List<Item>>的方法，我想把这个列表中的每一个项目向下传递给一个返回Completable的方法。我希望等到每个项目成功完成并返回一个Completable结果。我最初的方法是使用flatMapIterable分别处理每一项，并使用toList组合结果，但不能在Completable对象上调用toList。还有其他方法可以以这种方式将许多Completable任务“聚合”到单个Completable中吗？到目前为止，我的情况如下：
public Single<List<Item>> getListOfItems(
浏览 4提问于2017-08-22得票数 1
回答已采纳
2回答
我有一个aspx页面，它接受一些输入并发出请求：
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(string.Format("{0}?{1}", strPostPath, strPostData));
request.Method = "GET";
request.Timeout = 5000; // set 5 sec. timeout
request.ProtocolVersion = HttpVersion.Version11;
try
{
Ht
浏览 3提问于2010-06-17得票数 1
3回答
func signup(_ username: String, password: String) -> Observable<Bool> {
// this is also just a mock
let signupResult = arc4random() % 5 == 0 ? false : true
return Observable.just(signupResult)
.concat(Observable.never())
.throttle(0.4, scheduler: MainScheduler.in
浏览 4提问于2016-11-27得票数 2
回答已采纳
3回答
我有一个只有4个URL的UrlList，我想用它来发出4个并发请求。下面的代码真的发出了4个同时开始的请求吗？ 我的测试似乎表明它是正确的，但是我认为实际上将有4个请求同时从URL目标检索数据的想法是正确的，还是看起来是这样的？ static void Main(string[] args)
{
var t = Do_TaskWhenAll();
t.Wait();
}
public static async Task Do_TaskWhenAll()
{
var downloadTasksQuery
浏览 49提问于2020-08-13得票数 0
回答已采纳
1回答
我们是新的角度，我们有很少的方法需要按顺序调用并返回一个值。在这里，返回是在完成执行之前调用的。我尝试过不同的东西，比如异步等待，承诺，setTimeout，但是没有运气。是否有任何解决方案可以按角度同步顺序工作？
transform(input:any)
{
this.getCachedUsers(); // this will set the this.CachedUsers array using a http get call(subscribe)
this.getUserFromCachedUsers(input); // this will set the thi
浏览 3提问于2022-04-06得票数 0
我的角组件中有一个可观察的订阅，它使用路由解析器返回视图的数据，如下所示：
ngOnInit(): void {
console.log("start");
this._activatedRoute.data //this returns an observable after executing an http request to get the data.
.subscribe((x) => {
console.log("in subscribe")
// set com
浏览 2提问于2022-07-24得票数 0
你好社区
我正在尝试使用HttpClient模块从我的api中获取一些数据。
api调用在我的服务中定义。我在组件中的Lifecyclehooks中将它们命名为Lifecyclehooks，但我很难理解返回的可观测值的行为，以及如何在ngOnInit中获得它的值。
我构建了一个示例代码，它记录返回的数据对象以了解它们的行为。服务函数返回可观测的。
--这就是我的示例代码的样子：
我的样品服务：
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/h
浏览 5提问于2020-01-08得票数 2
回答已采纳
我是RxSwift框架的新手。我在ViewController中使用一次性设备，并在DisposeBag中添加一次性设备。 我应该在哪里释放DisposeBag，以便处理所有一次性设备？在控制器的viewDidAppear或deinit中？哪种方法更安全？
浏览 33提问于2019-03-07得票数 1
1回答
我使用react.js将XML文件发送到服务器，并希望在服务器做出响应之前呈现一个加载器。 我尝试了一个文件组件，它是有效的。但我想使用三个不同的文件，每个文件都有不同的大小和响应时间。 我有这样的东西。 class UploadFiles extends Component {
state = {
isLoading: null }
// Omitted code for upload files to the state
uploadData(file){
// Omitted Code <- Asynchronous function, each file
浏览 20提问于2019-02-06得票数 1
回答已采纳
1回答
用RxSwift建立网络
、、、、
我一直在努力理解rxSwift。我面临着请求问题，并希望以一种良好的方式来实现这一点。目前，我正在使用以下代码：
enum RequestState<T> {
case loading
case loaded(T)
case error(Error)
}
struct Response<T: Decodable>: Decodable {
let data: T
let error: ResponseError?
}
searchBar.rx.text.asObservable()
.flatMap { self.pr
浏览 0提问于2018-10-06得票数 0
2回答
我一直在试验一些新的快速架构和模式，我注意到RxSwift中有一个奇怪的问题，如果我正在进行一个服务调用，并且出现了一个错误，例如用户输入了错误的密码，那么它似乎会处理我的订阅，所以我不能再次进行服务调用。
我不知道为什么会发生这种事。我做了一个简单的小项目，用一个示例登录应用程序演示了这个问题。
我的ViewModel看起来像这样
import RxSwift
import RxCocoa
import RxCoordinator
import RxOptional
extension LoginModel : ViewModelType {
struct Input {
浏览 0提问于2018-09-04得票数 3
回答已采纳
1回答
我有一系列的对象。我必须通过一个API调用来检查每个对象，以确定该对象是否有资格获得某个特定的宣传。在调用最后一个对象时，可观察到的对象应该返回false，或者其中一个对象从API中获得一个真正的状态，什么是最好的方法来继续用对象调用API？
目前，我已经将它作为代码使用，但感觉应该有一个更好的方法来处理RxJS操作符。
checkProductForPromo(items: []) {
const promoChecker$ = new EventEmitter<boolean>();
items.forEach((item, key, arr) => {
浏览 0提问于2019-09-09得票数 1
回答已采纳
可观察的与主语的区别是什么？当我定义一个可观察的类型变量时。它可以发出onNext，onComplete，onDispose。然而，主体也可以这样做。什么时候我应该使用可观察的，在什么情况下我应该使用主语？
浏览 0提问于2017-07-17得票数 17
回答已采纳
1回答
这可能是个蹩脚的问题，但我对角度并不熟悉，对那些可观测到的东西我也不太了解。
我得到了一些代码，其中第二个选择的选项取决于第一个选择值。有一个refreshPeople()方法，它在第一个选择变更时调用，该方法尝试将加载设置为true，然后对数据进行异步调用，然后将加载设置为false。
但是refreshPeople()中的最后一个命令不是等待异步调用结束。:(
在angular2+中制作这类东西的正确方法是什么？
因此，模板是：
Gender: {{gender}}
<ng-select
[items]="genders"
(change)="r
浏览 3提问于2020-08-21得票数 0
回答已采纳
3回答
在ngOnInit上，我为数据发出了4个http请求，然后需要从服务器加载数据，然后根据最后4个http调用的数据模型填充表单。
简而言之，我需要订阅这4个http调用，如果它们没有失败，确保它们不会失败。最后，我可以调用第五个http调用从服务器获取数据。
据我所知，我应该避免侵入一个可以观察到的开关，但是如何使用4 http调用来实现呢？我是否应该为http呼叫创建一个可观察的等待，如果成功地在第5个http调用上使用了开关映射？
这是密码。
ngOnInit() {
this.service.getProvince().subscribe(
(valu
浏览 2提问于2019-01-31得票数 2
回答已采纳
我有两个可以观察到的：initialLessons$和searchLessons$。initialLessons$最初显示已完成的课程的http提取请求。searchLessons$ request是一个可观察的fromEvent，它侦听按钮单击keyup事件，并在单击search按钮(带有filter参数)按钮后执行。
现在，如果我有this.lessons$ = concat(initialLessons$, searchlessons$)，通常，来自rxjs的操作符首先执行第一个可观测的，然后等待它完成，然后执行第二个可观测的。
如果我已经完成了第一个可观察到的初始请求，它是否“跳过”完
浏览 5提问于2022-07-24得票数 0
回答已采纳
1回答
在我的角度应用程序中，我们有一个进程按钮，它调用后端服务来保存问题的数据更改，并为正在读取的问题翻转一个标志。
我希望使我的HTTP调用是同步的(等待)，这样我就可以确定数据是否保存成功。如果数据保存成功，我们将显示绿色材料快餐店和成功信息。如果呼叫失败，我们将显示带有错误信息的红色物料快餐店。
最初，一切都是一个订阅，它是异步的。我根据我遇到的一些文章做了以下的事情。
const savedFacilityInfo = this.facility.updateFacilityInfo(this.savedFacilityInfo).toPromise();
savedFacili
浏览 4提问于2022-01-12得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
