This commit is contained in:
Olivier Yiptong 2014-06-10 11:09:44 -04:00
Родитель 35751400ce
Коммит 276034ed00
1 изменённых файлов: 0 добавлений и 3 удалений

Просмотреть файл

@ -301,14 +301,11 @@ Stream.prototype = {
*/
return Task.spawn(function() {
let worker = this.objects[objectIdent];
//console.log("process payload: " + JSON.stringify(payload));
let payloadCopy = JSON.parse(JSON.stringify(payload));
//console.log("working: " + objectIdent);
let newPayload = yield worker.consume(payloadCopy, flush);
if (newPayload) {
let listeners = this.listensTo[worker.emitType] || [];
//console.log("adding to work queue: " + JSON.stringify(listeners));
let promises = [];
if (!newPayload.terminate) {
for (let ident of listeners) {