safequeue - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

lib/queue.js

@@ -81,3 +81,8 @@ /* vim: set expandtab tabstop=2 shiftwidth=2 foldmethod=marker: */
 
-    return _sequence.push(build(item, tmout, this));
+    var n = _sequence.push(build(item, tmout, this));
+    if (1 === n) {
+      this.emit('fill');
+    }
+
+    return n;
   };
@@ -84,0 +89,0 @@ /* }}} */

package.json

 {
   "name": "safequeue",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "author": "Aleafs Zhang ([e-mail])",
@@ -5,0 +5,0 @@ "contributors": [],

README.md

@@ -23,2 +23,5 @@ [![Build Status](https://secure.travis-ci.org/aleafs/safequeue.png?branch=master)](http://travis-ci.org/aleafs/safequeue)
 
+queue.on('fill', function () {
+});
+
 queue.on('full', function (len, max) {
@@ -25,0 +28,0 @@ });

test/queue.test.js

@@ -15,3 +15,3 @@ /* vim: set expandtab tabstop=2 shiftwidth=2 foldmethod=marker: */
     var _messages = [];
-    ['full', 'timeout'].forEach(function (i) {
+    ['fill', 'full', 'timeout'].forEach(function (i) {
       _me.on(i, function () {
@@ -29,3 +29,3 @@ _messages.push([i].concat(Array.prototype.slice.call(arguments)));
     process.nextTick(function () {
-      _messages.should.eql([]);
+      _messages.should.eql([['fill']]);
       _me.shift().should.eql(1);
@@ -38,3 +38,3 @@ _me.shift().should.eql('a');
         _me.size().should.eql(0);
-        _messages.should.eql([[
+        _messages.should.eql([['fill'],[
           'timeout', 'c', 5, 0
@@ -54,3 +54,3 @@ ]]);
     var _messages = [];
-    ['full', 'timeout'].forEach(function (i) {
+    ['fill', 'full', 'timeout'].forEach(function (i) {
       _me.on(i, function () {
@@ -69,3 +69,3 @@ _messages.push([i].concat(Array.prototype.slice.call(arguments)));
 
-    _messages.should.eql([['full', 5, 5]]);
+    _messages.should.eql([['fill'],['full', 5, 5]]);
     _messages = [];
@@ -78,3 +78,3 @@
     setTimeout(function () {
-      _messages.should.eql([['timeout', 'x', 5, 0]]);
+      _messages.should.eql([['fill'],['timeout', 'x', 5, 0]]);
       done();
@@ -81,0 +81,0 @@ }, 8);

No alert changes

Improved metrics

Total package byte prevSize

7840

increased by1.99%

Lines of code

182

increased by2.25%

Number of lines in readme file

62

increased by5.08%

No dependency changes