1 files changed, 0 insertions, 92 deletions
diff --git a/build/priorityQueue.js b/build/priorityQueue.js
deleted file mode 100644
index 8f02f16..0000000
--- a/build/priorityQueue.js
+++ /dev/null
@@ -1,92 +0,0 @@
-'use strict';
-
-Object.defineProperty(exports, "__esModule", {
-    value: true
-});
-
-exports.default = function (worker, concurrency) {
-    function _compareTasks(a, b) {
-        return a.priority - b.priority;
-    }
-
-    function _binarySearch(sequence, item, compare) {
-        var beg = -1,
-            end = sequence.length - 1;
-        while (beg < end) {
-            var mid = beg + (end - beg + 1 >>> 1);
-            if (compare(item, sequence[mid]) >= 0) {
-                beg = mid;
-            } else {
-                end = mid - 1;
-            }
-        }
-        return beg;
-    }
-
-    function _insert(q, data, priority, callback) {
-        if (callback != null && typeof callback !== 'function') {
-            throw new Error('task callback must be a function');
-        }
-        q.started = true;
-        if (!(0, _isArray2.default)(data)) {
-            data = [data];
-        }
-        if (data.length === 0) {
-            // call drain immediately if there are no tasks
-            return (0, _setImmediate2.default)(function () {
-                q.drain();
-            });
-        }
-        (0, _arrayEach2.default)(data, function (task) {
-            var item = {
-                data: task,
-                priority: priority,
-                callback: typeof callback === 'function' ? callback : _noop2.default
-            };
-
-            q.tasks.splice(_binarySearch(q.tasks, item, _compareTasks) + 1, 0, item);
-
-            if (q.tasks.length === q.concurrency) {
-                q.saturated();
-            }
-            (0, _setImmediate2.default)(q.process);
-        });
-    }
-
-    // Start with a normal queue
-    var q = (0, _queue2.default)(worker, concurrency);
-
-    // Override push to accept second parameter representing priority
-    q.push = function (data, priority, callback) {
-        _insert(q, data, priority, callback);
-    };
-
-    // Remove unshift function
-    delete q.unshift;
-
-    return q;
-};
-
-var _arrayEach = require('lodash/_arrayEach');
-
-var _arrayEach2 = _interopRequireDefault(_arrayEach);
-
-var _isArray = require('lodash/isArray');
-
-var _isArray2 = _interopRequireDefault(_isArray);
-
-var _noop = require('lodash/noop');
-
-var _noop2 = _interopRequireDefault(_noop);
-
-var _setImmediate = require('./setImmediate');
-
-var _setImmediate2 = _interopRequireDefault(_setImmediate);
-
-var _queue = require('./queue');
-
-var _queue2 = _interopRequireDefault(_queue);
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
-module.exports = exports['default'];
-\ No newline at end of file