observable相关内容
我有一个使用参数 :client_name 的 Angular 路由,以及一个带有方法 getClientDetails(client_name) 的服务,用于从基于 的 HTTP API 获取数据:client_name.两者都是独立工作的 Observable 方法,但是当我组合 2 个 observable 时,API 调用会在获取参数之前运行(client_name 未定义): thi
..
假设我有一个 Observable,就像这样: var one = someObservable.take(1);one.subscribe(function(){/* 做某事 */}); 然后,我有第二个Observable: var two = someOtherObservable.take(1); 现在,我想subscribe()到two,但我想确保one在之前完成两个订阅者被解雇
..
我根本不明白 mergeMap 的目的.我听说有两种解释: 这就像 .NET LINQ 中的 SelectAll() - 不是. 它是 RxJS merge 和 map 的组合 - 不(或者我无法复制). 考虑以下代码: var obs1 = new Rx.Observable.interval(1000);var obs2 = new Rx.Observable.interva
..
我有一组看起来相当笨重的代码,其中来自一个 observable 的数据被馈送到另一个,如下所示: let source = this.myService.getFoo().订阅(结果 => {让 source2 = this.myService.getMoo(result).subscribe(result2 => {//做事 });}); 我知道有多种方法可以组合和链接,但我需要将源中的数
..
我正在尝试进行 API 调用(使用 angular4),该调用在失败时使用 retryWhen 重试.我希望它延迟 500 毫秒并重试.这可以通过以下代码实现: loadSomething(): Observable{返回 this.http.get(this.someEndpoint, commonHttpHeaders()).retryWhen(errors => errors.delay(
..
我想知道,当 unsubscribe 之后使用 unsubscribe 时,使用 .take(1) 和 .unsubscribe 之间是否有任何性能差异订阅: var observable = Rx.Observable.interval(100); 首先: var subscription = observable.subscribe(function(value) {控制台日志(值);}
..
简化以下代码示例的方法是什么?我找不到合适的操作员..谁能举一个简短的例子? this.returnsObservable1(...).订阅(成功 =>{this.returnsObservable2(...).订阅(成功 =>{this.returnsObservable3(...).订阅(成功 =>{...}, 解决方案 如评论中所述,您正在寻找 flatMap 运算符. 您可以在
..
我需要将三个数据从三个不同的 API 传递给一个函数: this.service.service1().subscribe( res1 => {this.service.service1().subscribe( res2 => {this.service.service1().subscribe( res3 => {this.funcA(res1, res2, res3);});});});
..
我使用 NestJS 基本上使用 HttpService(一个可观察的封装 Axios 库)将请求代理到另一个 api.例如: 返回 this.httpService.post(...).管道(地图(响应 => 响应.数据),); 这在调用成功时正常工作;但是,如果出现错误 (4xx),我该如何正确返回状态和错误消息? 我已经想出了如何使用 promise 来实现,但如果可能的话,我希望
..
Object.Observe 的 MDN 表示 Observe 现在已过时,我们应该使用“更通用的 Proxy 对象". 但 Observe 允许拦截现有对象的更改.如果 Proxy 不允许,那么 Proxy API 并不比 Observable API“更通用". MDN for Proxy 和 这个问题给出了拦截代理更改的例子对象,但永远不要谈论对底层对象的更改. 代理是否应
..
我有这个下拉菜单,可以选择车辆是新车还是二手车. NuevoUsado` 还有这个输入: ` 如果选择的下拉列表中的值是 New,则必须禁用输入,如果使用,则应启用输入,但如果我输入一个值,observable 将获取该值,
..
我想知道knockoutjs是否可以在绑定时传递参数. 我正在绑定一个复选框列表,并希望绑定到我的视图模型中的单个计算 observable.在我的视图模型中(基于传递给读取函数的参数),我想根据某些条件返回真/假. var myViewModel=function(){this.myprop=ko.computed({读取:函数(){//想在这里接收一个参数来执行我的逻辑并根据参数返回.
..
我有一个带有可观察变量的 observableArray 对象的 viewModel. 我的模板显示带有编辑按钮的数据,该按钮隐藏显示元素并显示具有绑定值的输入元素.您可以开始编辑数据,然后您可以选择取消.我希望这个取消恢复到对象的未更改版本. 我尝试通过执行以下操作来克隆对象: viewModel.tempContact = jQuery.extend({}, contact);
..
我想显示一个可编辑的项目列表,其中的每个项目都是可编辑的(某种程度上类似于可编辑的网格).我正在使用 KnockoutJS.我不能只使用一个简单的 Observable 数组,因为正如文档所述“一个 observableArray 跟踪数组中的哪些对象,而不是这些对象的状态" 因此,我创建了一个可观察对象的 observableArray(使用 utils.arrayMap),并将它们绑定到
..
在收到新值之前,是否有可能在淘汰赛中获得对该 observable 的订阅中的 observable 的当前值? 示例: this.myObservable = ko.observable();this.myObservable.subscribe(function(newValue){//我想在这里获取'myObservable'之前的值,然后再将它设置为newValue}); 解决方
..
我正在使用 APP_INITIALIZER,就像 this 答案中推荐的那样,我的服务返回了一个承诺,但它没有t 总是等待它解决,我可以看到我的组件 console.logging 未定义,然后服务记录下载的对象. 我需要应用程序在加载此数据之前不执行任何操作. app.module.ts import { NgModule, APP_INITIALIZER } from '@ang
..
我有一个具有这种方法的服务: 导出类 TestModelService {公共测试模型:测试模型;构造函数(@Inject(Http)公共http:Http){}public fetchModel(uuid: string = undefined): Observable{如果(!uuid){//返回 JSON.stringify(new TestModel()) 的 Observable;}别
..
在使用 rxjs 的 Angular 2 中,我试图将 Promise 转换为 Observable.正如许多在线指南所示,我在 Observable 上使用了 fromPromise.哪个抛出错误: 属性 'fromPromise' 不存在于类型 'typeof Observable' 上. Observable 是这样导入的: import { Observable } from "rx
..
我很难找到在 Angular2 服务中使用 observable 的示例/指南.有一些 html 模板绑定 EventEmitter 的东西,但这似乎不适合服务. 在 Angular2 中远离 Promises 是一大驱动主题,但我似乎无法正确理解新语法. 我在做什么 我有一个 FirebaseAuth 服务,可以注入到其他服务或组件. 我有一个函数可以异步调用firebase
..
我发现了这个问题 SwiftUI:将多个 BindableObjects 放入环境 答案说 environmentObject(ObservableObject) 返回修改后的视图,因此我可以为多个 environmentObject 创建调用链. 喜欢 let rootView = ContentView().environmentObject(firstBindable).env
..