| /** PURE_IMPORTS_START tslib,_innerSubscribe PURE_IMPORTS_END */ | 
| import * as tslib_1 from "tslib"; | 
| import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe'; | 
| export function expand(project, concurrent, scheduler) { | 
|     if (concurrent === void 0) { | 
|         concurrent = Number.POSITIVE_INFINITY; | 
|     } | 
|     concurrent = (concurrent || 0) < 1 ? Number.POSITIVE_INFINITY : concurrent; | 
|     return function (source) { return source.lift(new ExpandOperator(project, concurrent, scheduler)); }; | 
| } | 
| var ExpandOperator = /*@__PURE__*/ (function () { | 
|     function ExpandOperator(project, concurrent, scheduler) { | 
|         this.project = project; | 
|         this.concurrent = concurrent; | 
|         this.scheduler = scheduler; | 
|     } | 
|     ExpandOperator.prototype.call = function (subscriber, source) { | 
|         return source.subscribe(new ExpandSubscriber(subscriber, this.project, this.concurrent, this.scheduler)); | 
|     }; | 
|     return ExpandOperator; | 
| }()); | 
| export { ExpandOperator }; | 
| var ExpandSubscriber = /*@__PURE__*/ (function (_super) { | 
|     tslib_1.__extends(ExpandSubscriber, _super); | 
|     function ExpandSubscriber(destination, project, concurrent, scheduler) { | 
|         var _this = _super.call(this, destination) || this; | 
|         _this.project = project; | 
|         _this.concurrent = concurrent; | 
|         _this.scheduler = scheduler; | 
|         _this.index = 0; | 
|         _this.active = 0; | 
|         _this.hasCompleted = false; | 
|         if (concurrent < Number.POSITIVE_INFINITY) { | 
|             _this.buffer = []; | 
|         } | 
|         return _this; | 
|     } | 
|     ExpandSubscriber.dispatch = function (arg) { | 
|         var subscriber = arg.subscriber, result = arg.result, value = arg.value, index = arg.index; | 
|         subscriber.subscribeToProjection(result, value, index); | 
|     }; | 
|     ExpandSubscriber.prototype._next = function (value) { | 
|         var destination = this.destination; | 
|         if (destination.closed) { | 
|             this._complete(); | 
|             return; | 
|         } | 
|         var index = this.index++; | 
|         if (this.active < this.concurrent) { | 
|             destination.next(value); | 
|             try { | 
|                 var project = this.project; | 
|                 var result = project(value, index); | 
|                 if (!this.scheduler) { | 
|                     this.subscribeToProjection(result, value, index); | 
|                 } | 
|                 else { | 
|                     var state = { subscriber: this, result: result, value: value, index: index }; | 
|                     var destination_1 = this.destination; | 
|                     destination_1.add(this.scheduler.schedule(ExpandSubscriber.dispatch, 0, state)); | 
|                 } | 
|             } | 
|             catch (e) { | 
|                 destination.error(e); | 
|             } | 
|         } | 
|         else { | 
|             this.buffer.push(value); | 
|         } | 
|     }; | 
|     ExpandSubscriber.prototype.subscribeToProjection = function (result, value, index) { | 
|         this.active++; | 
|         var destination = this.destination; | 
|         destination.add(innerSubscribe(result, new SimpleInnerSubscriber(this))); | 
|     }; | 
|     ExpandSubscriber.prototype._complete = function () { | 
|         this.hasCompleted = true; | 
|         if (this.hasCompleted && this.active === 0) { | 
|             this.destination.complete(); | 
|         } | 
|         this.unsubscribe(); | 
|     }; | 
|     ExpandSubscriber.prototype.notifyNext = function (innerValue) { | 
|         this._next(innerValue); | 
|     }; | 
|     ExpandSubscriber.prototype.notifyComplete = function () { | 
|         var buffer = this.buffer; | 
|         this.active--; | 
|         if (buffer && buffer.length > 0) { | 
|             this._next(buffer.shift()); | 
|         } | 
|         if (this.hasCompleted && this.active === 0) { | 
|             this.destination.complete(); | 
|         } | 
|     }; | 
|     return ExpandSubscriber; | 
| }(SimpleOuterSubscriber)); | 
| export { ExpandSubscriber }; | 
| //# sourceMappingURL=expand.js.map |