observable

    0热度

    1回答

    我有一个关于观察到的问题。 例如,我们的API,并发送reguest有: this.http.get('https://swapi.co/api/people/').subscribe(peoplesData => { let peoples = peoplesData.json(); let nextPage = peoples.next; // https://swapi.

    0热度

    1回答

    我想从一个数组上的另一个observable返回一个Observable。我使用该数组查找两个值并进行计算。目前我正在使用一个很好的承诺,但为了我自己的理解,我想知道它是如何完成的。 如何转换下面的代码返回一个无极 convertToCurrency(fromCurrency: string, toCurrency: string) { return new Promise((res

    0热度

    1回答

    我对Angular4相当陌生,需要为我构建的简单服务编写单元测试,但不知道从哪里开始。 import { Injectable } from '@angular/core'; import { Observable } from 'rxjs/Observable'; import { HttpClient } from '@angular/common/http'; import 'rxjs

    1热度

    3回答

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

    0热度

    2回答

    有没有办法让一个Observable只抛出一个例外发生在像flatMap()功能? 在Java中,在一个正常的功能,你可以指定它可能会抛出异常: public void dangerousFunction() throws IOException {} 在像flatMap()一个Observable功能,我似乎无法找到类似的语法。我可以用一个try/catch这样的: myObservable

    0热度

    1回答

    有人可以帮助我想出一个函数,我可以将其应用于可以防止排放快速发生的可观察项。 val later = Subject[Int]() val combined = Observable.from(List(1,2,3,4,5,6,7,8)) ++ later combined.delayMinTime(1 second).doOnEach(...) 通常情况下,这会发出1-8,然后'随后'任

    1热度

    1回答

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

    -1热度

    1回答

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

    -1热度

    1回答

    非常新Observables所以道歉,如果这是基本的,但我已经尝试了谷歌搜索,并且似乎无法找到我想要的。 这是一个示例plunkr,非常基本。 https://plnkr.co/edit/kgECPQyoKqY7RamebUUu?p=preview 为什么我的Initialized方法在我的服务调用它之前不会调用?我认为initialized观测值将尽快执行Observable.forkJoin

    1热度

    1回答

    我使用requirejs/crossroads设置。 这是我的引导与一些全局属性: ko.applyBindings({ route: router.currentRoute, user: { ... }, ... loading: ko.observable(false), setLoadingState: function