一 take操作符
只发出源 Observable 最初发出的的N个值 (N = count
)。 如果源发出值的数量小于 count
的话,那么它的所有值都将发出。然后它便完成,无论源 Observable 是否完成。
import { Component, OnInit } from ‘@angular/core‘;import { range } from ‘rxjs/observable/range‘;import { take } from ‘rxjs/operators/take‘;@Component({ ?selector: ‘app-filter‘, ?templateUrl: ‘./filter.component.html‘, ?styleUrls: [‘./filter.component.css‘]})export class FilterComponent implements OnInit { ?constructor() { } ?ngOnInit() { ???range(100, 10) ?????.pipe(take(5)) ?????.subscribe(val => { ???????console.log(val); ?????}); ?}}
RxJS之过滤操作符 ( Angular环境 )
原文地址:https://www.cnblogs.com/sea-breeze/p/8969237.html