Файловый менеджер - Редактировать - /home/freeclou/app.optimyar.com/backend/node_modules/rxjs/_esm2015/internal/operators/take.js
Назад
import { Subscriber } from '../Subscriber'; import { ArgumentOutOfRangeError } from '../util/ArgumentOutOfRangeError'; import { empty } from '../observable/empty'; export function take(count) { return (source) => { if (count === 0) { return empty(); } else { return source.lift(new TakeOperator(count)); } }; } class TakeOperator { constructor(total) { this.total = total; if (this.total < 0) { throw new ArgumentOutOfRangeError; } } call(subscriber, source) { return source.subscribe(new TakeSubscriber(subscriber, this.total)); } } class TakeSubscriber extends Subscriber { constructor(destination, total) { super(destination); this.total = total; this.count = 0; } _next(value) { const total = this.total; const count = ++this.count; if (count <= total) { this.destination.next(value); if (count === total) { this.destination.complete(); this.unsubscribe(); } } } } //# sourceMappingURL=take.js.map
| ver. 1.4 |
Github
|
.
| PHP 8.1.33 | Генерация страницы: 0 |
proxy
|
phpinfo
|
Настройка