rxjs

1热度

1回答

我想使用webpack 3和rxjs5来运行一个简单的打字稿项目，但是我收到一个错误。 app.ts： import { Observable } from 'rxjs/Observable'; import 'rxjs/add/observable/of'; const myObservable: any = Observable.of(1, 2, 3)

1热度

3回答

tslint错误盯梢的名字：“可观测”

运行，我没有得到之前当tslint我收到以下错误.. ERROR: C:/...path..to../observable-debug-operator.ts[27, 13]: Shadowed name: 'Observable' 我跟着这个tutorial添加一个调试操作人员可观察到的，这是工作正常，除非我得到这个皮棉错误。我一直使用这个调试运算符一段时间没有得到lint错误，我不知道为什

0热度

1回答

Angular 2：如何在全局范围内处理http oauth authtoken 401错误

我想使用全局错误处理程序处理访问令牌，并使用刷新令牌刷新它们。我的解决方案，几乎似乎工作如下： ROM您的组件，订阅可观察到如下： this.myHttpService.getSomeData().subscribe(response => { console.log('user logged in', response); }, error => {

2热度

2回答

如何定位并从Observable中删除主题？

我正在使用服务从调查问卷收集用户响应。一切流动的方式是这样的 questionnaire.component.ts：主容器，从question.service.ts 问题，shell.component.ts临危数据：使用questionnaire.component.ts迭代问题的组成部分。其它输入组件：几个组件，以适应不同类型的，它发送useer响应返回到question-shell.com

0热度

1回答

Angular，RxJS：为具有AsyncSubject源的Observable分配一个新值

我需要创建服务，其中包含服务从服务器获取的设置。这些设置是在应用程序中广泛使用，而不是只在一个地方： @Injectable() export class SettingsService { private apiResource = '/settings'; private settingsSubject$: AsyncSubject<Settings> = new Asy

1热度

1回答

使用rxjs预订毁灭金字塔.subscribe with Angular - 压扁.subscribees的数量

我目前正在调查RxJS's .merge但是我还会问这里的问题，因为我在这里找到的解释有时很棒。好的，我有一个表单，根据用户输入打开一个模式窗口，我订阅模式关闭事件并传回一些数据，我会在调用/订阅服务方法以检索一些数据后使用，那么当发生这种情况时，我再次做同样的事情，然后调用/订阅另一个服务方法来更新某个日期，然后在完成后运行本地方法。所以，我在这里是3套.subscribe小号 const d

0热度

1回答

在mat表中使用ConnectableObservable而不是DataSource

从我所了解的表中可以看出，表dataSource是一个Observable的薄包装，其接口看起来很像ConnectableObservable。后有点挖我的意识到rxjs/ConnectableObservable的连接方法将返回Disposable或更可能一个Subscription根据自己信任的来源。这与材料中预期的API不太匹配。在材料网站上给出的例子确实为一些不明确的原因声明了额外的

-1热度

1回答

角4分重复点击GET HTTP观察数据多次

我有这样的服务，这为我提供了数据从API为可观察到的。在我的组件中，如果用户双击get方法，数据将被多次推入到数组中。我对RxJs库很新，但我有一种感觉，可以用.switchMap（）修复，使用BehaviorSubject或者使用|异步管道？ “hitsArray” - 数组，包含HTML中的数据作为ngFor - 来自http get的responsedata，如果用户通过“spam”函数将

0热度

1回答

如何成对缓冲观察值并通过对执行它们？

我有越来越与我执行后续XHR请求，像这样的阵列的XHR请求： const Rx = require('rxjs/Rx'); const fetch = require('node-fetch'); const url = `url`; // Get array of tables const tables$ = Rx.Observable .from(fetch(url).t

1热度

1回答

RxJs：到2个独立的观测

观察到触发我有一个观察的名为“workcentersFiltered”式的Observable<Workcenter[]> 当我选择一个厂，我可以成功过滤了我用下面的代码工作中心 - 没问题： this.workcentersFiltered = this.newLineForm.get('plant').valueChanges .flatMap(selectedPlant =>