1 /** PURE_IMPORTS_START tslib,_Subscriber PURE_IMPORTS_END */
2 import * as tslib_1 from "tslib";
3 import { Subscriber } from '../Subscriber';
4 export function bufferCount(bufferSize, startBufferEvery) {
5 if (startBufferEvery === void 0) {
6 startBufferEvery = null;
8 return function bufferCountOperatorFunction(source) {
9 return source.lift(new BufferCountOperator(bufferSize, startBufferEvery));
12 var BufferCountOperator = /*@__PURE__*/ (function () {
13 function BufferCountOperator(bufferSize, startBufferEvery) {
14 this.bufferSize = bufferSize;
15 this.startBufferEvery = startBufferEvery;
16 if (!startBufferEvery || bufferSize === startBufferEvery) {
17 this.subscriberClass = BufferCountSubscriber;
20 this.subscriberClass = BufferSkipCountSubscriber;
23 BufferCountOperator.prototype.call = function (subscriber, source) {
24 return source.subscribe(new this.subscriberClass(subscriber, this.bufferSize, this.startBufferEvery));
26 return BufferCountOperator;
28 var BufferCountSubscriber = /*@__PURE__*/ (function (_super) {
29 tslib_1.__extends(BufferCountSubscriber, _super);
30 function BufferCountSubscriber(destination, bufferSize) {
31 var _this = _super.call(this, destination) || this;
32 _this.bufferSize = bufferSize;
36 BufferCountSubscriber.prototype._next = function (value) {
37 var buffer = this.buffer;
39 if (buffer.length == this.bufferSize) {
40 this.destination.next(buffer);
44 BufferCountSubscriber.prototype._complete = function () {
45 var buffer = this.buffer;
46 if (buffer.length > 0) {
47 this.destination.next(buffer);
49 _super.prototype._complete.call(this);
51 return BufferCountSubscriber;
53 var BufferSkipCountSubscriber = /*@__PURE__*/ (function (_super) {
54 tslib_1.__extends(BufferSkipCountSubscriber, _super);
55 function BufferSkipCountSubscriber(destination, bufferSize, startBufferEvery) {
56 var _this = _super.call(this, destination) || this;
57 _this.bufferSize = bufferSize;
58 _this.startBufferEvery = startBufferEvery;
63 BufferSkipCountSubscriber.prototype._next = function (value) {
64 var _a = this, bufferSize = _a.bufferSize, startBufferEvery = _a.startBufferEvery, buffers = _a.buffers, count = _a.count;
66 if (count % startBufferEvery === 0) {
69 for (var i = buffers.length; i--;) {
70 var buffer = buffers[i];
72 if (buffer.length === bufferSize) {
74 this.destination.next(buffer);
78 BufferSkipCountSubscriber.prototype._complete = function () {
79 var _a = this, buffers = _a.buffers, destination = _a.destination;
80 while (buffers.length > 0) {
81 var buffer = buffers.shift();
82 if (buffer.length > 0) {
83 destination.next(buffer);
86 _super.prototype._complete.call(this);
88 return BufferSkipCountSubscriber;
90 //# sourceMappingURL=bufferCount.js.map