rxjs

    0热度

    1回答

    我有一个带有布尔变量的Angular 4组件。初始值取决于输入流。 TypeScript要求我声明变量,如下例所示。没有它,this.isLoading会触发错误。 在这一点上,我不知道它的价值,所以我只声明它没有分配一个变量。 export class SomeComponent implements OnInit { @Input() someStream$; isLoad

    3热度

    3回答

    RxJS 5.5做出了重大改变,并引入了lettable operators来替换我们以前用过的所有运营商(称为“运营商”)。 该文章包含一张纸条: Lettable operators can now be imported from rxjs/operators, but doing so without changing your build process will often resul

    0热度

    1回答

    我工作需要使用的WebSocket的,因此服务器可以快速将数据推到Web UI的一个项目工作。我正在使用angular-cli的Angular v5。然而,我很难让websocket连接在失败时重试。 对于那些有兴趣我的项目在其当前状态,可以发现here。 我跟着this tutorial,但还没有真正能够得到与rxjs原则交手。我一直在做很多试验和错误,现在就到我所​​在的位置。 所以我创建了一

    1热度

    1回答

    我正在分析我的角度应用程序包,我不明白为什么rxjs导入一个功能模块1.b6e2bed6d2a2d3892bd9.chunk.js,我在该模块导入的所有内容如下所示: import { Observable } from 'rxjs/Observable'; 如何找出为什么整个rxjs是模块是进口?

    0热度

    1回答

    我有一个(费时)计算,类似的东西: async calculation(input: MyInputType): Promise<MyOutputType> { // fetch some infos from an HTTP endpoint // calculate result by combining received infos with input ret

    0热度

    1回答

    我是一个noobie with observables,我试图创建一个可观察的点击流来忽略双击时发生的2个点击事件,但我得到这个错误: - Unhandled Promise rejection: this.clickStream.buffer is not a function ; Zone: <root> ; Task: Promise.then ; Value: TypeError: thi

    0热度

    1回答

    我是RxJS的新手。我正在使用RxJs 5.5.2 为了保持简单,我希望每次在主题上调用next时都返回缩小的值。下面是一个示例代码: const sub = new Subject<number>(); const obsesvable = sub.pipe( reduce((a, b) => { return a + b; }, 0) ); obsesvab

    1热度

    1回答

    RxJS版本扫描:5.5.2 我有一个数组const v = [1, 2, 3]; 我希望能够创建此数组中的主体和行为像一个可观察到它消耗1,2,3的值。之后,我想要像一个主题。 这是我遇到麻烦的地方。我需要在每个主题中附加时间上,则初始值v = [1, 2, 3]使用reduce另一个值使用scan 下面是代码: const v = [1, 2, 3]; const sub = new Sub

    1热度

    2回答

    RxJS 5.5.2 我有下面的代码谁分裂的数字阵列为对象,具有2个属性“小”的数字越小则4和'大'其余。 const o = from([1, 2, 3, 4, 5, 6]).pipe( scan<number, {}>((a, b) => { if (b < 4) { a['small'].push(b); } else { a['big']

    0热度

    1回答

    如何使用RxJS实现类似以下内容的操作? ABCDEFGH AB CD --- --- --- EF GH 或 ABCDEFGH ABC ---- ----高清GH 我有一个数组,我需要按指定的分区分割并以指定的时间间隔发射值。