来自 RxJs 的 Angular 2 返回数据订阅
我有一个带有身份验证功能的服务 - authenticate(username: string, password: string) {让退；让数据包 = JSON.stringify({用户名:用户名，密码:密码});让标题=新标题()；headers.append('Content-Type', 'application/json');this.http.post('http://local
..
rxjs相关内容
RxJS 中的 `map` 方法是什么意思?
我正在通过阅读本教程学习 RxJS http://reactive-extensions.github.io/learnrx/. 我很难理解地图 Observable 的方法.map 的Array 版本非常简单明了.我不知道 map 在 Observable 的情况下究竟意味着什么(以及为什么它有一个名为 select 的别名?！). 这是文档告诉我的.可能对大多数初学者没有帮助...
..
Angular2 RxJS 获取“Observable_1.Observable.fromEvent 不是函数"错误
我正在使用 AngularJS 2 Beta 0 并且我正在尝试从窗口对象上的事件创建一个 RxJS Observable.我相信我知道在我的服务中将事件捕获为 Observable 的公式: var observ = Observable.fromEvent(this.windowHandle, 'hashchange'); 问题是，每次我尝试运行此代码时，都会收到一条错误消息，指出“fro
..
如何在链接的 observables 之间传递结果
抽象问题: 每次源 Observable 发出和事件时，都需要触发一系列 API 调用和 Angular 服务.其中一些调用取决于之前的结果. 在我的示例中，源 Observable startUpload$ 触发了一系列依赖调用. 使用解构可以这样写: this.startUploadEvent$.pipe(concatMap(event => this.getAuthentica
..
在 Angular 中使用 shareReplay(1) - 仍然调用 http 请求?
我创建了一个演示(ng-run)我有一个调用 Http 请求的按钮. 当按钮被点击时，我调用这个方法: public getData(){this._jokeService.getData().subscribe();} 依次调用它(从服务中): public getData() {返回 this.http.get(API_ENDPOINT).pipe(shareReplay(1))
..
tap() vs subscribe() 设置类属性
我对 rxjs 非常陌生，只是想知道是否可以通过管道传输流并点击它来设置类属性，或者我应该在订阅中进行设置.对我来说，无论哪种方式都有效，只是想知道是否可以按照我认为适合自己的方式进行操作，或者有什么我不知道的事情. 展示两种方式的打字稿代码: 导出类 ViewComponent 实现 OnInit {申请人 = {};构造函数(公共路线:ActivatedRoute，私人商店:Store
..
什么是 observable、observer 和 subscribe ?
我正在学习 angular，但我对这些 observable、observer 和 subscribe 感到困惑事物.所以请解释一下. 解决方案 这是一个简单的视觉效果，可以看出区别: 如上所示......Observable 是一个事件或数据流.它们通常从 Angular 方法返回，例如 http.get 和 myinputBox.valueChanges. 订阅“启动"可观
..
函数名末尾的 $ 符号表示什么?
这是我正在审查的代码... import { Observable } from 'rxjs/Rx';//减速器从 './player' 导入 { playerRegister, PlayerState };导出函数 getPlayer$(state$: Observable): Observable{返回 state$.select(state => state.player);}; 解决方
..
我什么时候应该使用 `publishReplay` 和 `shareReplay`?
我已经知道了 publish 共享一个订阅并返回一个 ConnectableObservable(所以我们必须Connect()) Share() 是 publish().refcount() Replay 后缀非常明显，它返回最后一次发射. 让我们以现在和未来订阅的 Angular HTTP 请求为例:
{{ (person | async)?.id }}
..
Node.js Streams 与 Observables
在了解了 Observables 之后，我发现它们与 Node.js 流.两者都有一种机制，可以在新数据到达、发生错误或没有更多数据 (EOF) 时通知消费者. 我很想了解两者之间的概念/功能差异.谢谢！ 解决方案 Observables 和 node.js 的 Streams 都允许您解决相同的底层问题:异步处理一个值序列.我认为，两者之间的主要区别与促使其出现的背景有关.该上下文
..
Angular:订阅 Observable 时，AgGrid 不会更新行
我正在尝试将 rxjs 和 observables 合并到 ag 网格中.为了练习，我正在关注一个官方的 ag 网格示例:https://www.ag-grid.com/javascript-grid-rxjs/ 我目前使用的是 Angular 6.我将 js 文件更改为 ts 文件并进行了适当的更改.我的索引文件中也不包含任何脚本.每次调用脚本时，我都会收到一堆 MIME 错误.所以我将代
..
如何从 2 个 http 请求以 angular 构建单个对象，而不添加另一个值
如果你看看这个 问题.问题真的很简单，但解决方案更复杂，为了解决更多细节，我问了这个问题. 如果您查看服务中的 stackblitz代码尝试在将对象传递给组件之前构建对象.我遇到的问题是代码添加的键值，它破坏了表单控件. 第一个响应返回包含只有这些值的路由的对象. addressPointId: "地址",市政ID:“市政"，regionId: "regionId",结算ID:“结
..
暂停一个间隔 rxjs
我有一个简单的秒表，使用 rxjs 问题是:无法获得如何暂停我的间隔流，然后继续它stackbiz 解决方案 我看到秒表问题经常出现，我觉得创建一个自定义的 stopWatch observable 会很有趣.RxJS 方式是通过切换进入和退出计时器/间隔来实现这一点. 另一种有趣的实现方式是使用 setTimeout 代替.setTimeout 实际上应该需要更少的内存，因为
..
将单个订阅变量与 BehaviorSubject 一起使用
我在我的 Angular 应用程序中使用 BehaviorSubject 并且我可以从 DataService 观察到我的 Details 组件，如图所示下面: DataService.ts: 导出类数据服务{private messageTracker = new BehaviorSubject();private fileTracker = new BehaviorSubject();
..
Angular2 2.0.x 和 Rx 5 beta.12 包
我目前正在更新我的项目的依赖项，该项目使用 Angular2 npm 包，因此也使用 RxJs.我正在更新到依赖 Rx5 beta.12 的 2.0.2 稳定版 angular.对于我的 Web 应用程序，我只部署 Rx.min.js 包并在我的 index.html 文件中使用脚本标记加载它.这种方法之前在 Rx umd 包中运行良好，但同时会导致错误，因为在我看来，RxJs 的贡献者为了一个公
..
RxJs Subject.subscribe 方法没有按预期工作
Subject.subscribe 方法在调用时输出以下错误: TypeError: 无法读取未定义的属性“_subscribe"在 BidirectionalSubject._subscribe (Rx.js:10239)在 BidirectionalSubject._subscribe (Rx.js:10239)在 BidirectionalSubject.Observable.subscr
..
将观察者存储在全局变量中并稍后使用
如何在代码中创建一个 observable 并生成下一个值?由于其他异步事件，我希望能够从代码的不同部分调用 onNext. 这是我尝试过的，但不起作用: var Rx = require('rx');var GlobalObserver;var source = Rx.Observable.create(observer => {GlobalObserver = 观察者；});var 订
..
RxJs:拖放示例:添加 mousedragstart
如何使用 mousedragstart Observable="nofollow">拖放 RxJs 的示例. mousedragstart 应该在 mousedown 之后的第一个 mousedrag 之前发出，直到 mouseup. 我认为我们必须使用 flatMap/take(1)/takeUntil(mouseup) 但我每次都失败了.. 更新 这里的困难不是避免 m
..
观察者订阅不会在第一次加载到组件时触发
我有一个公开 asObservable 的商店.一个视图订阅它并显示数据.自从我将其更改为单例服务以来，它一直在首次加载，当我第一次进入该页面时，没有显示任何数据，也没有触发订阅事件.在我对数据执行一些操作后，导致被称为 subject.next 的它更新，视图更新，一切都很好. 我已确保这不是竞争条件问题，并且在调用页面的构造函数时数据在存储中. 事件顺序如下(调试时确认):
..
使用 Subject.create 创建的主题无法取消订阅
我有一个负责订阅某些 observable 的主题: var timer$ = Rx.Observable.timer(1000, 2000); 当主题像那样链接到主题时 var timerSubject = new Rx.Subject;定时器$.subscribe(timerSubject);var subscription1 = timerSubject.subscribe(n =>
..