1 /** PURE_IMPORTS_START tslib,_Subscriber PURE_IMPORTS_END */
2 import * as tslib_1 from "tslib";
3 import { Subscriber } from '../Subscriber';
4 export function skip(count) {
5 return function (source) { return source.lift(new SkipOperator(count)); };
7 var SkipOperator = /*@__PURE__*/ (function () {
8 function SkipOperator(total) {
11 SkipOperator.prototype.call = function (subscriber, source) {
12 return source.subscribe(new SkipSubscriber(subscriber, this.total));
16 var SkipSubscriber = /*@__PURE__*/ (function (_super) {
17 tslib_1.__extends(SkipSubscriber, _super);
18 function SkipSubscriber(destination, total) {
19 var _this = _super.call(this, destination) || this;
24 SkipSubscriber.prototype._next = function (x) {
25 if (++this.count > this.total) {
26 this.destination.next(x);
29 return SkipSubscriber;
31 //# sourceMappingURL=skip.js.map