split def. fix

This commit is contained in:
Marcin Porebski 2015-02-26 10:46:05 +01:00
parent 3c74c3686d
commit b164150c40

View File

@ -6,11 +6,11 @@ import split = require("split");
var testStream = new stream.Readable();
testStream.pipe = function(dest) {
testStream.pipe = function(dest: stream.Writable) {
dest.write("This is \r\n new \r\n line");
return dest;
};
testStream.pipe(split(/(\r?\n)/, null, {maxLength: 20})).on("data", function(line) {
console.log("Line: " + line + "\r\n");
testStream.pipe(split(/(\r?\n)/, null, {maxLength: 20})).on("data", function(line: Buffer) {
console.log("Line: " + line.toString('ascii') + "\r\n");
});