Comparing version 1.0.2 to 1.0.3
@@ -6,5 +6,2 @@ "use strict"; | ||
}); | ||
function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; } | ||
var Runner = function Runner(env, kafkaHost, registry) { | ||
@@ -16,27 +13,8 @@ var send = function send(topic, payload) { | ||
var receive = function () { | ||
var _ref = _asyncToGenerator(regeneratorRuntime.mark(function _callee(payload, topic) { | ||
var task; | ||
return regeneratorRuntime.wrap(function _callee$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
// receive messages from kafka | ||
task = registry[topic]; | ||
_context.next = 3; | ||
return task.subscribe(payload); | ||
var receive = function receive(payload, topic) { | ||
// receive messages from kafka | ||
var task = registry[topic]; | ||
task.subscribe(payload); | ||
}; | ||
case 3: | ||
case "end": | ||
return _context.stop(); | ||
} | ||
} | ||
}, _callee, undefined); | ||
})); | ||
return function receive(_x, _x2) { | ||
return _ref.apply(this, arguments); | ||
}; | ||
}(); | ||
return { | ||
@@ -43,0 +21,0 @@ send: send, |
{ | ||
"name": "steveo", | ||
"version": "1.0.2", | ||
"version": "1.0.3", | ||
"description": "A Task Manager Library", | ||
@@ -20,2 +20,5 @@ "main": "lib/index.js", | ||
}, | ||
"files": [ | ||
"lib/*" | ||
], | ||
"devDependencies": { | ||
@@ -27,2 +30,3 @@ "babel-cli": "^6.24.0", | ||
"babel-plugin-transform-flow-strip-types": "^6.22.0", | ||
"babel-polyfill": "^6.23.0", | ||
"babel-preset-es2015": "^6.24.0", | ||
@@ -29,0 +33,0 @@ "babel-preset-stage-1": "^6.22.0", |
6322
19
6
106