You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							169 lines
						
					
					
						
							7.0 KiB
						
					
					
				
			
		
		
		
			
			
			
				
					
				
				
					
				
			
		
		
	
	
							169 lines
						
					
					
						
							7.0 KiB
						
					
					
				| "use strict"; | |
| var __extends = (this && this.__extends) || (function () { | |
|     var extendStatics = function (d, b) { | |
|         extendStatics = Object.setPrototypeOf || | |
|             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || | |
|             function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; }; | |
|         return extendStatics(d, b); | |
|     } | |
|     return function (d, b) { | |
|         extendStatics(d, b); | |
|         function __() { this.constructor = d; } | |
|         d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); | |
|     }; | |
| })(); | |
| Object.defineProperty(exports, "__esModule", { value: true }); | |
| var Subject_1 = require("../Subject"); | |
| var async_1 = require("../scheduler/async"); | |
| var Subscriber_1 = require("../Subscriber"); | |
| var isNumeric_1 = require("../util/isNumeric"); | |
| var isScheduler_1 = require("../util/isScheduler"); | |
| function windowTime(windowTimeSpan) { | |
|     var scheduler = async_1.async; | |
|     var windowCreationInterval = null; | |
|     var maxWindowSize = Number.POSITIVE_INFINITY; | |
|     if (isScheduler_1.isScheduler(arguments[3])) { | |
|         scheduler = arguments[3]; | |
|     } | |
|     if (isScheduler_1.isScheduler(arguments[2])) { | |
|         scheduler = arguments[2]; | |
|     } | |
|     else if (isNumeric_1.isNumeric(arguments[2])) { | |
|         maxWindowSize = Number(arguments[2]); | |
|     } | |
|     if (isScheduler_1.isScheduler(arguments[1])) { | |
|         scheduler = arguments[1]; | |
|     } | |
|     else if (isNumeric_1.isNumeric(arguments[1])) { | |
|         windowCreationInterval = Number(arguments[1]); | |
|     } | |
|     return function windowTimeOperatorFunction(source) { | |
|         return source.lift(new WindowTimeOperator(windowTimeSpan, windowCreationInterval, maxWindowSize, scheduler)); | |
|     }; | |
| } | |
| exports.windowTime = windowTime; | |
| var WindowTimeOperator = (function () { | |
|     function WindowTimeOperator(windowTimeSpan, windowCreationInterval, maxWindowSize, scheduler) { | |
|         this.windowTimeSpan = windowTimeSpan; | |
|         this.windowCreationInterval = windowCreationInterval; | |
|         this.maxWindowSize = maxWindowSize; | |
|         this.scheduler = scheduler; | |
|     } | |
|     WindowTimeOperator.prototype.call = function (subscriber, source) { | |
|         return source.subscribe(new WindowTimeSubscriber(subscriber, this.windowTimeSpan, this.windowCreationInterval, this.maxWindowSize, this.scheduler)); | |
|     }; | |
|     return WindowTimeOperator; | |
| }()); | |
| var CountedSubject = (function (_super) { | |
|     __extends(CountedSubject, _super); | |
|     function CountedSubject() { | |
|         var _this = _super !== null && _super.apply(this, arguments) || this; | |
|         _this._numberOfNextedValues = 0; | |
|         return _this; | |
|     } | |
|     CountedSubject.prototype.next = function (value) { | |
|         this._numberOfNextedValues++; | |
|         _super.prototype.next.call(this, value); | |
|     }; | |
|     Object.defineProperty(CountedSubject.prototype, "numberOfNextedValues", { | |
|         get: function () { | |
|             return this._numberOfNextedValues; | |
|         }, | |
|         enumerable: true, | |
|         configurable: true | |
|     }); | |
|     return CountedSubject; | |
| }(Subject_1.Subject)); | |
| var WindowTimeSubscriber = (function (_super) { | |
|     __extends(WindowTimeSubscriber, _super); | |
|     function WindowTimeSubscriber(destination, windowTimeSpan, windowCreationInterval, maxWindowSize, scheduler) { | |
|         var _this = _super.call(this, destination) || this; | |
|         _this.destination = destination; | |
|         _this.windowTimeSpan = windowTimeSpan; | |
|         _this.windowCreationInterval = windowCreationInterval; | |
|         _this.maxWindowSize = maxWindowSize; | |
|         _this.scheduler = scheduler; | |
|         _this.windows = []; | |
|         var window = _this.openWindow(); | |
|         if (windowCreationInterval !== null && windowCreationInterval >= 0) { | |
|             var closeState = { subscriber: _this, window: window, context: null }; | |
|             var creationState = { windowTimeSpan: windowTimeSpan, windowCreationInterval: windowCreationInterval, subscriber: _this, scheduler: scheduler }; | |
|             _this.add(scheduler.schedule(dispatchWindowClose, windowTimeSpan, closeState)); | |
|             _this.add(scheduler.schedule(dispatchWindowCreation, windowCreationInterval, creationState)); | |
|         } | |
|         else { | |
|             var timeSpanOnlyState = { subscriber: _this, window: window, windowTimeSpan: windowTimeSpan }; | |
|             _this.add(scheduler.schedule(dispatchWindowTimeSpanOnly, windowTimeSpan, timeSpanOnlyState)); | |
|         } | |
|         return _this; | |
|     } | |
|     WindowTimeSubscriber.prototype._next = function (value) { | |
|         var windows = this.windows; | |
|         var len = windows.length; | |
|         for (var i = 0; i < len; i++) { | |
|             var window_1 = windows[i]; | |
|             if (!window_1.closed) { | |
|                 window_1.next(value); | |
|                 if (window_1.numberOfNextedValues >= this.maxWindowSize) { | |
|                     this.closeWindow(window_1); | |
|                 } | |
|             } | |
|         } | |
|     }; | |
|     WindowTimeSubscriber.prototype._error = function (err) { | |
|         var windows = this.windows; | |
|         while (windows.length > 0) { | |
|             windows.shift().error(err); | |
|         } | |
|         this.destination.error(err); | |
|     }; | |
|     WindowTimeSubscriber.prototype._complete = function () { | |
|         var windows = this.windows; | |
|         while (windows.length > 0) { | |
|             var window_2 = windows.shift(); | |
|             if (!window_2.closed) { | |
|                 window_2.complete(); | |
|             } | |
|         } | |
|         this.destination.complete(); | |
|     }; | |
|     WindowTimeSubscriber.prototype.openWindow = function () { | |
|         var window = new CountedSubject(); | |
|         this.windows.push(window); | |
|         var destination = this.destination; | |
|         destination.next(window); | |
|         return window; | |
|     }; | |
|     WindowTimeSubscriber.prototype.closeWindow = function (window) { | |
|         window.complete(); | |
|         var windows = this.windows; | |
|         windows.splice(windows.indexOf(window), 1); | |
|     }; | |
|     return WindowTimeSubscriber; | |
| }(Subscriber_1.Subscriber)); | |
| function dispatchWindowTimeSpanOnly(state) { | |
|     var subscriber = state.subscriber, windowTimeSpan = state.windowTimeSpan, window = state.window; | |
|     if (window) { | |
|         subscriber.closeWindow(window); | |
|     } | |
|     state.window = subscriber.openWindow(); | |
|     this.schedule(state, windowTimeSpan); | |
| } | |
| function dispatchWindowCreation(state) { | |
|     var windowTimeSpan = state.windowTimeSpan, subscriber = state.subscriber, scheduler = state.scheduler, windowCreationInterval = state.windowCreationInterval; | |
|     var window = subscriber.openWindow(); | |
|     var action = this; | |
|     var context = { action: action, subscription: null }; | |
|     var timeSpanState = { subscriber: subscriber, window: window, context: context }; | |
|     context.subscription = scheduler.schedule(dispatchWindowClose, windowTimeSpan, timeSpanState); | |
|     action.add(context.subscription); | |
|     action.schedule(state, windowCreationInterval); | |
| } | |
| function dispatchWindowClose(state) { | |
|     var subscriber = state.subscriber, window = state.window, context = state.context; | |
|     if (context && context.action && context.subscription) { | |
|         context.action.remove(context.subscription); | |
|     } | |
|     subscriber.closeWindow(window); | |
| } | |
| //# sourceMappingURL=windowTime.js.map
 |