kopia lustrzana https://github.com/c9/core
Move status parsing to git
rodzic
4e5f32395e
commit
def889f732
|
@ -106,7 +106,7 @@
|
|||
"c9.ide.run.build": "#0598fff697",
|
||||
"c9.ide.run.debug.xdebug": "#5c004d2d75",
|
||||
"c9.ide.save": "#5118b30230",
|
||||
"c9.ide.scm": "#91b9aef7d5",
|
||||
"c9.ide.scm": "#9d61ac9e2c",
|
||||
"c9.ide.terminal.monitor": "#35afa7f97f",
|
||||
"c9.ide.test": "#520fa1e6c5",
|
||||
"c9.ide.test.mocha": "#7844e1dc83",
|
||||
|
|
|
@ -8,7 +8,7 @@ define(function(require, exports, module) {
|
|||
var c9 = imports.c9;
|
||||
var ext = imports.ext;
|
||||
|
||||
var JSONStream = require("./json-stream");
|
||||
var JSONStream = require("json-stream");
|
||||
|
||||
/***** Initialization *****/
|
||||
|
||||
|
|
|
@ -1,47 +0,0 @@
|
|||
define(function(require, exports, module) {
|
||||
|
||||
var EventEmitter = require("events").EventEmitter;
|
||||
|
||||
module.exports = function(stream) {
|
||||
var emit = this.emit.bind(this);
|
||||
|
||||
var buffer = "";
|
||||
stream.on("data", function(chunk) {
|
||||
buffer += chunk;
|
||||
|
||||
var parts = buffer.split("\n");
|
||||
while (parts.length) {
|
||||
try {
|
||||
var message = JSON.parse(parts[0]);
|
||||
emit("data", message);
|
||||
parts.shift();
|
||||
}
|
||||
catch (e) {
|
||||
if (parts.length !== 1) {
|
||||
emit("error", e);
|
||||
parts.shift();
|
||||
}
|
||||
else {
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
buffer = parts.join("\n");
|
||||
});
|
||||
|
||||
stream.on("error", function(err){
|
||||
emit("error", err);
|
||||
});
|
||||
|
||||
stream.on("close", function(data){
|
||||
emit("close", data);
|
||||
});
|
||||
|
||||
this.write = function(data) {
|
||||
stream.write(JSON.stringify(data) + "\n");
|
||||
};
|
||||
};
|
||||
|
||||
module.exports.prototype = new EventEmitter();
|
||||
|
||||
});
|
Ładowanie…
Reference in New Issue