{"dependencies":[{"name":"tslib","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":1,"column":0,"index":0},"end":{"line":1,"column":33,"index":33}}],"key":"8R25577gwLd3n1hFG9VYnRLV9eE=","exportNames":["*"],"imports":1}},{"name":"../Subscription","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":2,"column":0,"index":34},"end":{"line":2,"column":47,"index":81}}],"key":"vTbFs/H3GAmbje8AWPORaP4vWKE=","exportNames":["*"],"imports":1}},{"name":"../util/lift","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":3,"column":0,"index":82},"end":{"line":3,"column":39,"index":121}}],"key":"4CWnJ0pAAHdfw8fC393IKzeACYc=","exportNames":["*"],"imports":1}},{"name":"./OperatorSubscriber","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":4,"column":0,"index":122},"end":{"line":4,"column":64,"index":186}}],"key":"aA6xM2Hw6XHTylKbb30hQFraJU0=","exportNames":["*"],"imports":1}},{"name":"../util/arrRemove","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":5,"column":0,"index":187},"end":{"line":5,"column":46,"index":233}}],"key":"AVmnHiUkAiyZGj7E/ZN+Rjk+A84=","exportNames":["*"],"imports":1}},{"name":"../scheduler/async","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":6,"column":0,"index":234},"end":{"line":6,"column":52,"index":286}}],"key":"GyxFmT1jS5ZK51fxVs2V/Q0yZZU=","exportNames":["*"],"imports":1}},{"name":"../util/args","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":7,"column":0,"index":287},"end":{"line":7,"column":44,"index":331}}],"key":"6Gyx37St8I+cXtPiYhK64gcs47M=","exportNames":["*"],"imports":1}},{"name":"../util/executeSchedule","data":{"asyncType":null,"isESMImport":true,"locs":[{"start":{"line":8,"column":0,"index":332},"end":{"line":8,"column":58,"index":390}}],"key":"W9Dw1uvKZILg6x1bL3f6eqHY89k=","exportNames":["*"],"imports":1}}],"output":[{"data":{"code":"__d(function (global, require, _$$_IMPORT_DEFAULT, _$$_IMPORT_ALL, module, exports, _dependencyMap) {\n  \"use strict\";\n\n  Object.defineProperty(exports, '__esModule', {\n    value: true\n  });\n  exports.bufferTime = bufferTime;\n  var _tslib = require(_dependencyMap[0], \"tslib\");\n  var _Subscription = require(_dependencyMap[1], \"../Subscription\");\n  var _utilLift = require(_dependencyMap[2], \"../util/lift\");\n  var _OperatorSubscriber = require(_dependencyMap[3], \"./OperatorSubscriber\");\n  var _utilArrRemove = require(_dependencyMap[4], \"../util/arrRemove\");\n  var _schedulerAsync = require(_dependencyMap[5], \"../scheduler/async\");\n  var _utilArgs = require(_dependencyMap[6], \"../util/args\");\n  var _utilExecuteSchedule = require(_dependencyMap[7], \"../util/executeSchedule\");\n  function bufferTime(bufferTimeSpan) {\n    var _a, _b;\n    var otherArgs = [];\n    for (var _i = 1; _i < arguments.length; _i++) {\n      otherArgs[_i - 1] = arguments[_i];\n    }\n    var scheduler = (_a = (0, _utilArgs.popScheduler)(otherArgs)) !== null && _a !== void 0 ? _a : _schedulerAsync.asyncScheduler;\n    var bufferCreationInterval = (_b = otherArgs[0]) !== null && _b !== void 0 ? _b : null;\n    var maxBufferSize = otherArgs[1] || Infinity;\n    return (0, _utilLift.operate)(function (source, subscriber) {\n      var bufferRecords = [];\n      var restartOnEmit = false;\n      var emit = function (record) {\n        var buffer = record.buffer,\n          subs = record.subs;\n        subs.unsubscribe();\n        (0, _utilArrRemove.arrRemove)(bufferRecords, record);\n        subscriber.next(buffer);\n        restartOnEmit && startBuffer();\n      };\n      var startBuffer = function () {\n        if (bufferRecords) {\n          var subs = new _Subscription.Subscription();\n          subscriber.add(subs);\n          var buffer = [];\n          var record_1 = {\n            buffer: buffer,\n            subs: subs\n          };\n          bufferRecords.push(record_1);\n          (0, _utilExecuteSchedule.executeSchedule)(subs, scheduler, function () {\n            return emit(record_1);\n          }, bufferTimeSpan);\n        }\n      };\n      if (bufferCreationInterval !== null && bufferCreationInterval >= 0) {\n        (0, _utilExecuteSchedule.executeSchedule)(subscriber, scheduler, startBuffer, bufferCreationInterval, true);\n      } else {\n        restartOnEmit = true;\n      }\n      startBuffer();\n      var bufferTimeSubscriber = (0, _OperatorSubscriber.createOperatorSubscriber)(subscriber, function (value) {\n        var e_1, _a;\n        var recordsCopy = bufferRecords.slice();\n        try {\n          for (var recordsCopy_1 = (0, _tslib.__values)(recordsCopy), recordsCopy_1_1 = recordsCopy_1.next(); !recordsCopy_1_1.done; recordsCopy_1_1 = recordsCopy_1.next()) {\n            var record = recordsCopy_1_1.value;\n            var buffer = record.buffer;\n            buffer.push(value);\n            maxBufferSize <= buffer.length && emit(record);\n          }\n        } catch (e_1_1) {\n          e_1 = {\n            error: e_1_1\n          };\n        } finally {\n          try {\n            if (recordsCopy_1_1 && !recordsCopy_1_1.done && (_a = recordsCopy_1.return)) _a.call(recordsCopy_1);\n          } finally {\n            if (e_1) throw e_1.error;\n          }\n        }\n      }, function () {\n        while (bufferRecords === null || bufferRecords === void 0 ? void 0 : bufferRecords.length) {\n          subscriber.next(bufferRecords.shift().buffer);\n        }\n        bufferTimeSubscriber === null || bufferTimeSubscriber === void 0 ? void 0 : bufferTimeSubscriber.unsubscribe();\n        subscriber.complete();\n        subscriber.unsubscribe();\n      }, undefined, function () {\n        return bufferRecords = null;\n      });\n      source.subscribe(bufferTimeSubscriber);\n    });\n  }\n});","lineCount":91,"map":[[7,2,9,0,"exports"],[7,9,9,0],[7,10,9,0,"bufferTime"],[7,20,9,0],[7,23,9,0,"bufferTime"],[7,33,9,0],[8,2,1,0],[8,6,1,0,"_tslib"],[8,12,1,0],[8,15,1,0,"require"],[8,22,1,0],[8,23,1,0,"_dependencyMap"],[8,37,1,0],[9,2,2,0],[9,6,2,0,"_Subscription"],[9,19,2,0],[9,22,2,0,"require"],[9,29,2,0],[9,30,2,0,"_dependencyMap"],[9,44,2,0],[10,2,3,0],[10,6,3,0,"_utilLift"],[10,15,3,0],[10,18,3,0,"require"],[10,25,3,0],[10,26,3,0,"_dependencyMap"],[10,40,3,0],[11,2,4,0],[11,6,4,0,"_OperatorSubscriber"],[11,25,4,0],[11,28,4,0,"require"],[11,35,4,0],[11,36,4,0,"_dependencyMap"],[11,50,4,0],[12,2,5,0],[12,6,5,0,"_utilArrRemove"],[12,20,5,0],[12,23,5,0,"require"],[12,30,5,0],[12,31,5,0,"_dependencyMap"],[12,45,5,0],[13,2,6,0],[13,6,6,0,"_schedulerAsync"],[13,21,6,0],[13,24,6,0,"require"],[13,31,6,0],[13,32,6,0,"_dependencyMap"],[13,46,6,0],[14,2,7,0],[14,6,7,0,"_utilArgs"],[14,15,7,0],[14,18,7,0,"require"],[14,25,7,0],[14,26,7,0,"_dependencyMap"],[14,40,7,0],[15,2,8,0],[15,6,8,0,"_utilExecuteSchedule"],[15,26,8,0],[15,29,8,0,"require"],[15,36,8,0],[15,37,8,0,"_dependencyMap"],[15,51,8,0],[16,2,9,7],[16,11,9,16,"bufferTime"],[16,21,9,26,"bufferTime"],[16,22,9,27,"bufferTimeSpan"],[16,36,9,41],[16,38,9,43],[17,4,10,4],[17,8,10,8,"_a"],[17,10,10,10],[17,12,10,12,"_b"],[17,14,10,14],[18,4,11,4],[18,8,11,8,"otherArgs"],[18,17,11,17],[18,20,11,20],[18,22,11,22],[19,4,12,4],[19,9,12,9],[19,13,12,13,"_i"],[19,15,12,15],[19,18,12,18],[19,19,12,19],[19,21,12,21,"_i"],[19,23,12,23],[19,26,12,26,"arguments"],[19,35,12,35],[19,36,12,36,"length"],[19,42,12,42],[19,44,12,44,"_i"],[19,46,12,46],[19,48,12,48],[19,50,12,50],[20,6,13,8,"otherArgs"],[20,15,13,17],[20,16,13,18,"_i"],[20,18,13,20],[20,21,13,23],[20,22,13,24],[20,23,13,25],[20,26,13,28,"arguments"],[20,35,13,37],[20,36,13,38,"_i"],[20,38,13,40],[20,39,13,41],[21,4,14,4],[22,4,15,4],[22,8,15,8,"scheduler"],[22,17,15,17],[22,20,15,20],[22,21,15,21,"_a"],[22,23,15,23],[22,26,15,26],[22,30,15,26,"popScheduler"],[22,39,15,38],[22,40,15,38,"popScheduler"],[22,52,15,38],[22,54,15,39,"otherArgs"],[22,63,15,48],[22,64,15,49],[22,70,15,55],[22,74,15,59],[22,78,15,63,"_a"],[22,80,15,65],[22,85,15,70],[22,90,15,75],[22,91,15,76],[22,94,15,79,"_a"],[22,96,15,81],[22,99,15,84,"asyncScheduler"],[22,114,15,98],[22,115,15,98,"asyncScheduler"],[22,129,15,98],[23,4,16,4],[23,8,16,8,"bufferCreationInterval"],[23,30,16,30],[23,33,16,33],[23,34,16,34,"_b"],[23,36,16,36],[23,39,16,39,"otherArgs"],[23,48,16,48],[23,49,16,49],[23,50,16,50],[23,51,16,51],[23,57,16,57],[23,61,16,61],[23,65,16,65,"_b"],[23,67,16,67],[23,72,16,72],[23,77,16,77],[23,78,16,78],[23,81,16,81,"_b"],[23,83,16,83],[23,86,16,86],[23,90,16,90],[24,4,17,4],[24,8,17,8,"maxBufferSize"],[24,21,17,21],[24,24,17,24,"otherArgs"],[24,33,17,33],[24,34,17,34],[24,35,17,35],[24,36,17,36],[24,40,17,40,"Infinity"],[24,48,17,48],[25,4,18,4],[25,11,18,11],[25,15,18,11,"operate"],[25,24,18,18],[25,25,18,18,"operate"],[25,32,18,18],[25,34,18,19],[25,44,18,29,"source"],[25,50,18,35],[25,52,18,37,"subscriber"],[25,62,18,47],[25,64,18,49],[26,6,19,8],[26,10,19,12,"bufferRecords"],[26,23,19,25],[26,26,19,28],[26,28,19,30],[27,6,20,8],[27,10,20,12,"restartOnEmit"],[27,23,20,25],[27,26,20,28],[27,31,20,33],[28,6,21,8],[28,10,21,12,"emit"],[28,14,21,16],[28,17,21,19],[28,26,21,19,"emit"],[28,27,21,29,"record"],[28,33,21,35],[28,35,21,37],[29,8,22,12],[29,12,22,16,"buffer"],[29,18,22,22],[29,21,22,25,"record"],[29,27,22,31],[29,28,22,32,"buffer"],[29,34,22,38],[30,10,22,40,"subs"],[30,14,22,44],[30,17,22,47,"record"],[30,23,22,53],[30,24,22,54,"subs"],[30,28,22,58],[31,8,23,12,"subs"],[31,12,23,16],[31,13,23,17,"unsubscribe"],[31,24,23,28],[31,25,23,29],[31,26,23,30],[32,8,24,12],[32,12,24,12,"arrRemove"],[32,26,24,21],[32,27,24,21,"arrRemove"],[32,36,24,21],[32,38,24,22,"bufferRecords"],[32,51,24,35],[32,53,24,37,"record"],[32,59,24,43],[32,60,24,44],[33,8,25,12,"subscriber"],[33,18,25,22],[33,19,25,23,"next"],[33,23,25,27],[33,24,25,28,"buffer"],[33,30,25,34],[33,31,25,35],[34,8,26,12,"restartOnEmit"],[34,21,26,25],[34,25,26,29,"startBuffer"],[34,36,26,40],[34,37,26,41],[34,38,26,42],[35,6,27,8],[35,7,27,9],[36,6,28,8],[36,10,28,12,"startBuffer"],[36,21,28,23],[36,24,28,26],[36,33,28,26,"startBuffer"],[36,34,28,26],[36,36,28,38],[37,8,29,12],[37,12,29,16,"bufferRecords"],[37,25,29,29],[37,27,29,31],[38,10,30,16],[38,14,30,20,"subs"],[38,18,30,24],[38,21,30,27],[38,25,30,31,"Subscription"],[38,38,30,43],[38,39,30,43,"Subscription"],[38,51,30,43],[38,52,30,44],[38,53,30,45],[39,10,31,16,"subscriber"],[39,20,31,26],[39,21,31,27,"add"],[39,24,31,30],[39,25,31,31,"subs"],[39,29,31,35],[39,30,31,36],[40,10,32,16],[40,14,32,20,"buffer"],[40,20,32,26],[40,23,32,29],[40,25,32,31],[41,10,33,16],[41,14,33,20,"record_1"],[41,22,33,28],[41,25,33,31],[42,12,34,20,"buffer"],[42,18,34,26],[42,20,34,28,"buffer"],[42,26,34,34],[43,12,35,20,"subs"],[43,16,35,24],[43,18,35,26,"subs"],[44,10,36,16],[44,11,36,17],[45,10,37,16,"bufferRecords"],[45,23,37,29],[45,24,37,30,"push"],[45,28,37,34],[45,29,37,35,"record_1"],[45,37,37,43],[45,38,37,44],[46,10,38,16],[46,14,38,16,"executeSchedule"],[46,34,38,31],[46,35,38,31,"executeSchedule"],[46,50,38,31],[46,52,38,32,"subs"],[46,56,38,36],[46,58,38,38,"scheduler"],[46,67,38,47],[46,69,38,49],[46,81,38,61],[47,12,38,63],[47,19,38,70,"emit"],[47,23,38,74],[47,24,38,75,"record_1"],[47,32,38,83],[47,33,38,84],[48,10,38,86],[48,11,38,87],[48,13,38,89,"bufferTimeSpan"],[48,27,38,103],[48,28,38,104],[49,8,39,12],[50,6,40,8],[50,7,40,9],[51,6,41,8],[51,10,41,12,"bufferCreationInterval"],[51,32,41,34],[51,37,41,39],[51,41,41,43],[51,45,41,47,"bufferCreationInterval"],[51,67,41,69],[51,71,41,73],[51,72,41,74],[51,74,41,76],[52,8,42,12],[52,12,42,12,"executeSchedule"],[52,32,42,27],[52,33,42,27,"executeSchedule"],[52,48,42,27],[52,50,42,28,"subscriber"],[52,60,42,38],[52,62,42,40,"scheduler"],[52,71,42,49],[52,73,42,51,"startBuffer"],[52,84,42,62],[52,86,42,64,"bufferCreationInterval"],[52,108,42,86],[52,110,42,88],[52,114,42,92],[52,115,42,93],[53,6,43,8],[53,7,43,9],[53,13,44,13],[54,8,45,12,"restartOnEmit"],[54,21,45,25],[54,24,45,28],[54,28,45,32],[55,6,46,8],[56,6,47,8,"startBuffer"],[56,17,47,19],[56,18,47,20],[56,19,47,21],[57,6,48,8],[57,10,48,12,"bufferTimeSubscriber"],[57,30,48,32],[57,33,48,35],[57,37,48,35,"createOperatorSubscriber"],[57,56,48,59],[57,57,48,59,"createOperatorSubscriber"],[57,81,48,59],[57,83,48,60,"subscriber"],[57,93,48,70],[57,95,48,72],[57,105,48,82,"value"],[57,110,48,87],[57,112,48,89],[58,8,49,12],[58,12,49,16,"e_1"],[58,15,49,19],[58,17,49,21,"_a"],[58,19,49,23],[59,8,50,12],[59,12,50,16,"recordsCopy"],[59,23,50,27],[59,26,50,30,"bufferRecords"],[59,39,50,43],[59,40,50,44,"slice"],[59,45,50,49],[59,46,50,50],[59,47,50,51],[60,8,51,12],[60,12,51,16],[61,10,52,16],[61,15,52,21],[61,19,52,25,"recordsCopy_1"],[61,32,52,38],[61,35,52,41],[61,39,52,41,"__values"],[61,45,52,49],[61,46,52,49,"__values"],[61,54,52,49],[61,56,52,50,"recordsCopy"],[61,67,52,61],[61,68,52,62],[61,70,52,64,"recordsCopy_1_1"],[61,85,52,79],[61,88,52,82,"recordsCopy_1"],[61,101,52,95],[61,102,52,96,"next"],[61,106,52,100],[61,107,52,101],[61,108,52,102],[61,110,52,104],[61,111,52,105,"recordsCopy_1_1"],[61,126,52,120],[61,127,52,121,"done"],[61,131,52,125],[61,133,52,127,"recordsCopy_1_1"],[61,148,52,142],[61,151,52,145,"recordsCopy_1"],[61,164,52,158],[61,165,52,159,"next"],[61,169,52,163],[61,170,52,164],[61,171,52,165],[61,173,52,167],[62,12,53,20],[62,16,53,24,"record"],[62,22,53,30],[62,25,53,33,"recordsCopy_1_1"],[62,40,53,48],[62,41,53,49,"value"],[62,46,53,54],[63,12,54,20],[63,16,54,24,"buffer"],[63,22,54,30],[63,25,54,33,"record"],[63,31,54,39],[63,32,54,40,"buffer"],[63,38,54,46],[64,12,55,20,"buffer"],[64,18,55,26],[64,19,55,27,"push"],[64,23,55,31],[64,24,55,32,"value"],[64,29,55,37],[64,30,55,38],[65,12,56,20,"maxBufferSize"],[65,25,56,33],[65,29,56,37,"buffer"],[65,35,56,43],[65,36,56,44,"length"],[65,42,56,50],[65,46,56,54,"emit"],[65,50,56,58],[65,51,56,59,"record"],[65,57,56,65],[65,58,56,66],[66,10,57,16],[67,8,58,12],[67,9,58,13],[67,10,59,12],[67,17,59,19,"e_1_1"],[67,22,59,24],[67,24,59,26],[68,10,59,28,"e_1"],[68,13,59,31],[68,16,59,34],[69,12,59,36,"error"],[69,17,59,41],[69,19,59,43,"e_1_1"],[70,10,59,49],[70,11,59,50],[71,8,59,52],[71,9,59,53],[71,18,60,20],[72,10,61,16],[72,14,61,20],[73,12,62,20],[73,16,62,24,"recordsCopy_1_1"],[73,31,62,39],[73,35,62,43],[73,36,62,44,"recordsCopy_1_1"],[73,51,62,59],[73,52,62,60,"done"],[73,56,62,64],[73,61,62,69,"_a"],[73,63,62,71],[73,66,62,74,"recordsCopy_1"],[73,79,62,87],[73,80,62,88,"return"],[73,86,62,94],[73,87,62,95],[73,89,62,97,"_a"],[73,91,62,99],[73,92,62,100,"call"],[73,96,62,104],[73,97,62,105,"recordsCopy_1"],[73,110,62,118],[73,111,62,119],[74,10,63,16],[74,11,63,17],[74,20,64,24],[75,12,64,26],[75,16,64,30,"e_1"],[75,19,64,33],[75,21,64,35],[75,27,64,41,"e_1"],[75,30,64,44],[75,31,64,45,"error"],[75,36,64,50],[76,10,64,52],[77,8,65,12],[78,6,66,8],[78,7,66,9],[78,9,66,11],[78,21,66,23],[79,8,67,12],[79,15,67,19,"bufferRecords"],[79,28,67,32],[79,33,67,37],[79,37,67,41],[79,41,67,45,"bufferRecords"],[79,54,67,58],[79,59,67,63],[79,64,67,68],[79,65,67,69],[79,68,67,72],[79,73,67,77],[79,74,67,78],[79,77,67,81,"bufferRecords"],[79,90,67,94],[79,91,67,95,"length"],[79,97,67,101],[79,99,67,103],[80,10,68,16,"subscriber"],[80,20,68,26],[80,21,68,27,"next"],[80,25,68,31],[80,26,68,32,"bufferRecords"],[80,39,68,45],[80,40,68,46,"shift"],[80,45,68,51],[80,46,68,52],[80,47,68,53],[80,48,68,54,"buffer"],[80,54,68,60],[80,55,68,61],[81,8,69,12],[82,8,70,12,"bufferTimeSubscriber"],[82,28,70,32],[82,33,70,37],[82,37,70,41],[82,41,70,45,"bufferTimeSubscriber"],[82,61,70,65],[82,66,70,70],[82,71,70,75],[82,72,70,76],[82,75,70,79],[82,80,70,84],[82,81,70,85],[82,84,70,88,"bufferTimeSubscriber"],[82,104,70,108],[82,105,70,109,"unsubscribe"],[82,116,70,120],[82,117,70,121],[82,118,70,122],[83,8,71,12,"subscriber"],[83,18,71,22],[83,19,71,23,"complete"],[83,27,71,31],[83,28,71,32],[83,29,71,33],[84,8,72,12,"subscriber"],[84,18,72,22],[84,19,72,23,"unsubscribe"],[84,30,72,34],[84,31,72,35],[84,32,72,36],[85,6,73,8],[85,7,73,9],[85,9,73,11,"undefined"],[85,18,73,20],[85,20,73,22],[85,32,73,34],[86,8,73,36],[86,15,73,44,"bufferRecords"],[86,28,73,57],[86,31,73,60],[86,35,73,64],[87,6,73,67],[87,7,73,68],[87,8,73,69],[88,6,74,8,"source"],[88,12,74,14],[88,13,74,15,"subscribe"],[88,22,74,24],[88,23,74,25,"bufferTimeSubscriber"],[88,43,74,45],[88,44,74,46],[89,4,75,4],[89,5,75,5],[89,6,75,6],[90,2,76,0],[91,0,76,1],[91,3]],"functionMap":{"names":["<global>","bufferTime","operate$argument_0","emit","startBuffer","executeSchedule$argument_2","createOperatorSubscriber$argument_1","createOperatorSubscriber$argument_2","createOperatorSubscriber$argument_4"],"mappings":"AAA;OCQ;mBCS;mBCG;SDM;0BEC;iDCU,sCD;SFE;wEIQ;SJkB,EK;SLO,aM,8CN;KDE;CDC"},"hasCjsExports":false},"type":"js/module"}]}