observable相关内容
我需要能够一个接一个地执行 3 个 observable，以便我可以在第二个中使用第一个的结果值，在第三个中使用第一个和第二个结果. 这样的事情(它不起作用，因为 serviceId 在第三个请求中不可见): private setupStuff(): void {this.initRouteParams().pipe(switchMap(serviceId => this.getFile
..
当我在获取另一个资源的结果后需要调用一个资源时，我总是嵌套订阅，如下所示: this.paymentService.getPayment(this.currentUser.uid, this.code).valueChanges().订阅(付款 => {this.payment = 付款；this.gymService.getGym(this.payment.gym).valueChanges(
..
我正在尝试实现这个大理石图，具有 N 个 sN$ 的 hipotesis，并且我正在将此流添加到 main$. s1$ +--1--------------------99------>s2$ +------3--------7------------------------------>main$ +---[1]-[1, 3]---[1, 7]---[99, 7]-------------->
..
我必须承认我正在用 Angular2 做我的第一步，我在这里遇到了一个问题，我在理解上有一些问题.我正在使用 angular2@2.0.0-beta.0，它依赖于 rxjs@5.0.0-beta.0. 我的目的是发出 HTTP 请求(到 REST 服务)并允许将响应发送给返回的 observable 的多个订阅者.如果我正确理解文档，我可以使用 publish() 函数来转换由例如返回的 O
..
目标:发出一系列同步 http 请求，并能够将它们作为一个可观察流订阅. 示例(不起作用): let query_arr = ['test1','test2','test3']函数 make_request(query_arr){如果(query_arr.length){让有效载荷 = JSON.stringify(query_arr[0]);让标题=新标题()；query_arr.spl
..
我有一个带计时器的子组件，每 2 秒我向服务器发送一次 api 调用.只要用户在页面上，即使他/她参加婚礼并打开页面(父组件窗口)，我也需要执行此调用. 这是我的组件中的一些代码: this.myTimer = Observable.timer(1, 2000);这个.myTimer.mergeMapTo(this.myService.doSomeWork(this.myId)).subs
..
在 RxJS 中，如何在创建后更改间隔设置? 到目前为止我有这个，但它不起作用 var observable = Rx.Observable.interval(500).map(function (data) { return "Hello World " + data; });observable.subscribe(console.log);设置超时(函数(){observable.i
..
我正在研究 Observables 及其与 EventEmitter 的差异，然后偶然发现了 Subjects(我可以看到 Angulars EventEmitter 是基于它的). 似乎 Observables 是单播的，而 Subjects 是多播的(然后一个 EE 只是一个将 .next 包装在发射中以提供正确接口的主题). Observables 看起来很容易实现 class
..
任何建议，如何以更承诺链的风格重写?: this.apiService.sendPutRequest('/api/users/activate', usrObj).pipe(地图(() => {return this.apiService.sendGetRequest('/api/users/' + this.currentUserId).pipe(地图(数据=> {返回 this.setAct
..
我是 Angular 的相对初学者，我正在努力理解我从 ng-bootstrap 项目中阅读的一些源代码.可以在这里找到源代码. 我对 ngOnInit 中的代码很困惑: ngOnInit(): void {const inputValues$ = _do.call(this._valueChanges, value => {this._userInput = 值；如果(this.edit
..
示例: var s1 = Observable.of([1, 2, 3]);var s2 = Observable.of([4, 5, 6]);s1.merge(s2).subscribe(val => {控制台日志(val)；}) 我想得到[1,2,3,4,5,6] 代替 [1,2,3] [4,5,6] 解决方案 forkJoin 效果很好，你只需要扁平化数组:
..
RxJS 的文档定义了 AsyncSubject 如下: AsyncSubject 是一个变体，其中只有 Observable 执行的最后一个值被发送给它的观察者，并且只有在执行完成时才发送. 我不知道在哪里/为什么我需要使用这个主题变体.有人可以提供一个解释或一个真实世界的例子来说明它为什么存在和它的优点吗? 解决方案 看起来它对于获取和缓存(一次性)资源很有用，因为通常 h
..
我想使用 RXJS Observable.基本上它工作正常，但我不仅需要在 observer.next() 和 observer.complete() 被调用时做出反应.如何获得 RXJS Observable 的 OnComplete 事件?在我看来，RXJS 文档令人困惑. 导出类服务{myMethod():Observable{return Observable.create((obser
..
鉴于这样的可观察性 Rx.Observable.of([1,2,3,4,5]) 它发出一个单个项目(即一个数组)，操作符是什么，它将把这个 observable 转换成一个发出 5 个单个项目(或任何数组由)? 示例在 .of 上，但是通过 promise 获取数组也是一样的，可能还有很多其他示例.不建议将 of 替换为 from 解决方案 我想不出现有的操作符可以做到这一点，但
..
尝试在模板 HTML 中显示从组件到服务调用的数据，该调用调用并返回 API，但出现此错误 错误错误:找不到类型为“object"的不同支持对象“[object Object]".NgFor 仅支持绑定到可迭代对象，例如数组. HTML {{item.name}} 组件 测试:任何；t
..
我知道我不能给 BehaviorSubject 一个 Observable 值，但我需要一种方法来解决这个问题.在应用程序初始化时，我正在获取当前用户(如果存在)，并且我需要为 BehaviorSubject 提供该潜在值.所以我的服务代码是这样的: private user = new BehaviorSubject(this.getUser());公共用户 $ = this.user.asO
..
我在转换 observable 时遇到问题.详情如下: 我有这样的数据 [{'firstName': '约翰','lastName': '现金',“年龄":20}]; 然后我从api获取这些数据: public getData(): Observable{返回 this.http.get('xxx').地图(响应 =>响应.json());} 然后，我想订阅这个: this.se
..
我不知道我做错了什么，但不知何故我无法读取数据，尽管数据来自服务器作为响应，甚至数据在我放入时在服务 extractData 方法中显示控制台，但在订阅功能内的组件中，它给了我未定义的信息.帮助我做错了什么，我假设这是异步的问题，但是，我不知道如何正确.任何帮助将是可观的.提前谢谢 Component.ts import { Component, Input, OnInit } from
..
我想将我的 json-array 投射到我创建的界面并希望在浏览器中显示它.我认为我的界面可能有问题，但我无法弄清楚...我需要更改什么才能运行我的代码? 界面: 导出接口 Video {身份证号码;名称:字符串；描述:字符串；createdAt:字符串；} app.ts import {JSONP_PROVIDERS, Jsonp} from '@angular/http';从'.
..
我有一个代码块，我在这样的链中调用 observables: getData().flatMap(results => {返回 callNextDataMethod(results);}.flatMap(results2 => {//下一个操作等等}) 现在，我知道 flatMap 将允许我将前一个 observable 的结果传递给下一个.但是，我需要的是既要做到这一点，又要在第一个上传递结
..
