I hate race conditions
This commit is contained in:
@@ -46,13 +46,14 @@ export default class QMPClient extends EventEmitter {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private async onData(data : Buffer) {
|
private async onData(data : Buffer) {
|
||||||
let msgraw = data.toString();
|
let msgraw = data.toString().split("\n");
|
||||||
|
for(var message in msgraw) {
|
||||||
let msg;
|
let msg;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
msg = JSON.parse(msgraw);
|
msg = JSON.parse(msgraw[message]);
|
||||||
} catch {
|
} catch {
|
||||||
this.emit("qmpreturn", '');
|
this.emit("qmpreturn", "");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -82,14 +83,15 @@ export default class QMPClient extends EventEmitter {
|
|||||||
break;
|
break;
|
||||||
};
|
};
|
||||||
default: {
|
default: {
|
||||||
this.emit("qmpreturn", '');
|
this.emit("qmpreturn", "");
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}else
|
}else
|
||||||
// for now just return an empty string.
|
// for now just return an empty string.
|
||||||
// This is a giant hack but avoids a deadlock
|
// This is a giant hack but avoids a deadlock
|
||||||
this.emit("qmpreturn", '');
|
this.emit("qmpreturn", "");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private onClose() {
|
private onClose() {
|
||||||
|
|||||||
Reference in New Issue
Block a user