From 6927eb0704ed83180ffc78bced883f353230391e Mon Sep 17 00:00:00 2001 From: vazitron Date: Wed, 18 Apr 2018 21:46:30 +0200 Subject: [PATCH] Fix typo in delay.js DelaySelectorObservable --- src/modular/observable/delay.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/modular/observable/delay.js b/src/modular/observable/delay.js index b02410d02..ae7ee7d64 100644 --- a/src/modular/observable/delay.js +++ b/src/modular/observable/delay.js @@ -120,7 +120,7 @@ DelayAbsoluteObservable.prototype.subscribe = function (o) { return obs.subscribe(o); }; -function DelaySelectorObseravble(source, subscriptionDelay, delayDurationSelector) { +function DelaySelectorObservable(source, subscriptionDelay, delayDurationSelector) { this.source = source; this._selector = null; this._subDelay = null; @@ -133,9 +133,9 @@ function DelaySelectorObseravble(source, subscriptionDelay, delayDurationSelecto ObservableBase.call(this); } -inherits(DelaySelectorObseravble, ObservableBase); +inherits(DelaySelectorObservable, ObservableBase); -DelaySelectorObseravble.prototype.subscribeCore = function (o) { +DelaySelectorObservable.prototype.subscribeCore = function (o) { var delays = new CompositeDisposable(), atEnd = false, subscription = new SerialDisposable(), @@ -203,7 +203,7 @@ module.exports = function delay () { new DelayAbsoluteObservable(source, dueTime, scheduler) : new DelayRelativeObservable(source, dueTime, scheduler); } else if (isObservable(firstArg) || isFunction(firstArg)) { - return new DelaySelectorObseravble(source, firstArg, arguments[2]); + return new DelaySelectorObservable(source, firstArg, arguments[2]); } else { throw new Error('Invalid arguments'); }