diff --git a/lib/defer-events.js b/lib/defer-events.js index 190e8c6..3d8a983 100644 --- a/lib/defer-events.js +++ b/lib/defer-events.js @@ -44,12 +44,14 @@ function deferEvents(eventsHash){ function queueCapacity(num){ if (!arguments.length) return this.queue.config.capacity; this.queue.config.capacity = num ? Number(num): 0; + this.queue.check(); return this; } function queueInterval(num){ if (!arguments.length) return this.queue.config.interval; this.queue.config.interval = num ? Number(num): 0; + this.queue.check(); return this; } diff --git a/test/unit/modules/defer-events-spec.js b/test/unit/modules/defer-events-spec.js index bebeb27..b808ee4 100644 --- a/test/unit/modules/defer-events-spec.js +++ b/test/unit/modules/defer-events-spec.js @@ -95,4 +95,10 @@ describe('.deferEvent(s) methods', function() { this.client.recordDeferredEvents(); }); + it('should clear internal queue timer when .queueInterval() is set to 0', function(){ + assert.ok(this.client.queue.timer); + this.client.queueInterval(0); + assert.isNull(this.client.queue.timer); + }); + });