Create tests

.eslintignore

@@ -1 +1,2 @@
 dist
+test

package.json

@@ -10,7 +10,8 @@
     "promise-queue"
   ],
   "description": "A simple and small library for promise-based queues",
-  "author": "Łaniewski Bartosz <laniewski.bartozzz@gmail.com> (http://laniewski.me/)",
+  "author":
+    "Łaniewski Bartosz <laniewski.bartozzz@gmail.com> (http://laniewski.me/)",
   "license": "MIT",
   "main": "dist/index.js",
   "repository": {
@@ -44,11 +45,13 @@
     "prettier": "^1.11.1"
   },
   "scripts": {
-    "flow": "flow",
-    "lint": "node_modules/.bin/eslint --fix src",
+    "test": "npm run test:eslint && npm run test:flow && npm run test:mocha",
+    "test:flow": "flow",
+    "test:mocha": "mocha --require babel-core/register",
+    "test:eslint": "eslint --fix src",
     "clean": "rm -rf dist",
     "build": "babel src -d dist",
     "watch": "babel src -d dist -w",
-    "prepare": "npm run clean && npm run lint && npm run flow && npm run build"
+    "prepare": "npm run clean && npm run test && npm run build"
   }
 }

test/index.js

@@ -0,0 +1,62 @@
+import chai  from "chai";
+import Queue from "../src/";
+
+describe("queue-promise", function () {
+  const expect = chai.expect;
+
+  let count = 0;
+  let queue = new Queue({
+    concurrency: 1,
+    interval: 500
+  });
+
+  const reject = () => new Promise((resolve, reject) => reject("Error"));
+  const resolve = () => new Promise((resolve, reject) => resolve("Success"));
+
+  describe("add(asyncTask)", function () {
+    it("should add a new task if valid", function () {
+      queue.add(reject);
+      queue.add(resolve);
+
+      expect(queue.collection.size).to.equal(2);
+    });
+
+    it("should reject a new task if not valid", function () {
+      try {
+        expect(queue.add(true)).to.throw();
+      } catch (err) {
+        expect(err).to.be.an.instanceof(Error);
+        expect(err.message).to.equal("You must provide a function, not boolean.");
+      }
+    });
+  });
+
+  describe("remove(key)", function () {
+    it("should remove a registered task", function () {
+      queue.remove(0);
+      queue.remove(1);
+
+      expect(queue.collection.size).to.equal(0);
+    });
+  });
+
+  describe("on(event, callback)", function () {
+    it("should handle events", function () {
+      queue.on("resolve", function(data){count += 1});
+      queue.on("reject", function(error){count += 1});
+    });
+  });
+
+  describe("start()", function () {
+    it("should handle events", function (done) {
+      queue.add(reject);
+      queue.add(resolve);
+      queue.start();
+
+      setTimeout(function () {
+        expect(count).to.equal(2);
+        done();
+      }, 1250);
+    });
+  });
+});