执行http请求时带有多个forkjoin的rxjs
我正在执行一些 http 请求并使用 rxjs 来成功通知结果: getReportings(departmentId: number): Observable{返回 Observable.forkJoin(this.http.get('/api/members/' + DepartmentId).map(res => res.json()),this.http.get('/api/repor
..
reactive-extensions-js相关内容
从流 onError 中恢复的惯用方法
免责声明:这是上一个2个依赖流的安全更新问题的延续 处理 RxJS(或任何其他 RX 实现)中允许流不终止的错误的惯用方法是什么? 相关代码是 function convert(unit, value) {无功请求 = {};请求[单位] = 值；var 转换 = $.ajax({方法:'POST'，网址:'./convert.php',数据:请求，数据类型:'json'}).承诺(
..
如何与 RxJs 异步加载图像并在所有加载时执行方法
我正在尝试将基于 Promise 的代码转换为 RxJs，但很难理解 Rx，尤其是 RxJs. 我有一个带路径的数组. var paths = ["imagePath1","imagePath2"]; 我喜欢用 Javascript 加载图片 var img = new Image();img.src = 图像路径；image.onload//
..
使用 RxJs 将分页请求转换为 Observable 流
我有一个以页面为单位返回数据的服务.对一页的响应包含有关如何查询下一页的详细信息. 我的方法是返回响应数据，然后如果有更多可用页面，则立即将延迟调用连接到相同的可观察序列. function getPageFromServer(index) {//返回测试用例的虚拟数据返回 {nextpage:index+1, data:[1,2,3]};}函数 getPagedItems(index)
..
Angular2 RxJS 获取“Observable_1.Observable.fromEvent 不是函数"错误
我正在使用 AngularJS 2 Beta 0 并且我正在尝试从窗口对象上的事件创建一个 RxJS Observable.我相信我知道在我的服务中将事件捕获为 Observable 的公式: var observ = Observable.fromEvent(this.windowHandle, 'hashchange'); 问题是，每次我尝试运行此代码时，都会收到一条错误消息，指出“fro
..
缺少 rxjs 平面图
我尝试链接多个 rx.js observables 并传递数据.Flatmap 应该是拟合运算符，但导入了 import { Observable } from 'rxjs/Observable'; 未找到: 错误 TS2339:属性 'flatmap' 在类型 'Observable' 上不存在 使用的是 rx.js 的 5.0.0-beta.6 版本. public getCurre
..
RxJS 在 Ajax 错误后继续侦听
RxJs 在出现内部可观察错误(Ajax 请求)时停止监听点击事件.我试图弄清楚如何让事件侦听器与按钮单击事件挂钩并优雅地处理内部 ajax 错误. 这是我的示例代码和 plunkr 的链接 var input = $("#testBtn");var test = Rx.Observable.fromEvent(input,'click');var testAjax = 函数(){返回 R
..
SignalR 和反应式组合
我发现了这个关于如何让 SignalR 和 Rx 很好地播放的小宝石: Rx 和反应式教程 然而，您可能已经注意到，这仅在从服务器 -> 客户端运行时才有效.有谁知道如何走另一条路?我希望我的框架更像 NServiceBus 那样基于“消息"，而更少 RPC(信号器标准示例往往是这样). 这是因为弱类型世界不太适合 RPC.在服务器端，我希望能够在客户端调用周围放置接口，但我不能
..
RxJs:轮询直到间隔完成或收到正确的数据
我如何使用 RxJs 在浏览器中执行以下场景: 提交数据到队列进行处理 取回作业 ID 每 1 秒轮询另一个端点，直到结果可用或 60 秒过去(然后失败) 我提出的中间解决方案: Rx.Observable.fromPromise(submitJobToQueue(jobData)).flatMap(jobQueueData =>Rx.Observable.间隔(1000).延
..
要求对 Reactive Extensions (RX) 进行清晰、如画的解释?
很长一段时间以来，我一直试图将头放在 RX 上.而且，说实话，我永远不确定我是否得到了它 - 或没有. 今天在http://reactive-extensions.github.com/RxJS/上找到了一个解释- 在我看来 - 太可怕了.它说: RxJS 之于事件，就像 Promise 之于异步. 太好了.这是一个充满复杂性的句子，如果你对RX是什么一无所知，那么在这句话之后你
..
将 RxJS Observable 收集到数组
我想使用 RxJS 来“桥接"异步事件世界与同步世界.具体来说，我想创建一个函数，该函数返回在某个时间间隔内收集的事件数组. 我可以创建 Observable 来做我想要的 var source = Rx.Observable.间隔(100/* 毫秒 */).bufferWithTime(1000).take(1) 我可以很好地打印正确的值 var subscription = s
..
ForkJoin 2 BehaviorSubjects
我有两个行为主题流，我想在没有运气的情况下分叉加入.正如我想象的那样，它返回了它的最后两个值.这有可能以某种方式实现吗? 它不是在主语之后调用. let stream1 = new BehaviorSubject(2);let stream2 = new BehaviorSubject('two');Observable.forkJoin(stream1, stream2).订阅(r =>
..
捕捉可观察对象之间的循环依赖
我有一个用户编程场景，用户最终可以创建两个相互依赖的 observable.RxJS 不允许循环依赖，据我所知，内存或堆栈达到了它的极限，onError 回调被触发，值为 true. 如何显式检测循环依赖并抛出更具描述性的错误消息? 这段代码说明了如何在 RxJS 中创建循环依赖: var obsA,obB;obsA = Rx.Observable.returnValue(42)
..
2 个依赖流的安全更新
作为练习，我正在尝试构建 2 个相互更新的依赖流. 测试应用程序只是一个“英寸 厘米"转换器，两个输入都可编辑. 我遇到的问题是我无法停止导致一个字段更改的递归. 为了更好地解释这个问题，让我们看一下代码的相关部分: var cmValue = new Rx.BehaviorSubject(0),inValue = new Rx.BehaviorSubject(0);# 处理程
..
从数组创建无限可重复的 Observable
假设我有一个数组 items 我知道我可以使用这个数组创建一个 observable Rx.Observable.fromArray(items) 我如何从这里创建一个惰性无限重复的可观察对象(即:只要有请求就重复这些项目)? 尝试过 Rx.Observable.fromArray(items).repeat() 但这不会延迟执行，因此会锁定浏览器. 解决方案 你不能用
..
如何取消组合的 RxJS observable
伙计们，我有一个使用 RxJS 来处理鼠标事件的应用程序.我正在将这些事件组合成更复杂的可观察“手势".其中一种手势是“摇晃". 我尝试编写的一系列事件是: 鼠标按下鼠标左移鼠标向右移动鼠标左移鼠标向右移动鼠标向上 我发现的是 鼠标按下鼠标向上鼠标左移鼠标向右移动鼠标左移鼠标向右移动 也触发了相同的结果. 我制作了一个在codepen上演示这个问题的小提琴. 我的一般问题
..
从流onError恢复的惯用方式
免责声明:它是先前 2个相关流的安全更新问题的延续 用于处理RxJS(或任何其他RX实现)中的错误而导致流不终止的 idiomatic 方法是什么? 相关代码是 function convert(unit，value){var request = {};request [unit] = value;var conversion = $ .ajax({方法:"POST"，网址:"./
..
使用RxJ将分页的请求转换为可观察的流
我有一项可返回页面中数据的服务.对一页的回复包含有关如何查询下一页的详细信息. 我的方法是返回响应数据，然后在有更多页面可用时立即将延迟的调用连接到相同的可观察序列. function getPageFromServer(index){//返回测试用例的伪数据返回{nextpage:index + 1，data:[1,2,3]}；}函数getPagedItems(index){返回Obs
..
带有多个forkjoin的rxjs在执行HTTP请求时
我正在执行一些http请求，并使用rxjs成功通知结果: getReportings(departmentId: number): Observable { return Observable.forkJoin( this.http.get('/api/members/' + departmentId).map(res => res.js
..
rxjs平面图丢失
我尝试链接多个rx.js可观察对象并传递数据. Flatmap应该是拟合运算符，但要导入 import { Observable } from 'rxjs/Observable'; 找不到: Error TS2339: Property 'flatmap' does not exist on type 'Observable' 使用rx.js的版本5.
..