Comparing version 0.1.10 to 0.2.0
var util = require('util'), | ||
events = require('events'); | ||
events = require('events'), | ||
dgram = require('dgram'); | ||
@@ -7,3 +8,5 @@ function Carrier(reader, listener, encoding, separator) { | ||
encoding = encoding || 'utf-8'; | ||
var event = reader.constructor === dgram.Socket ? 'message' : 'data'; | ||
self.reader = reader; | ||
@@ -18,7 +21,11 @@ | ||
} | ||
var buffer = ''; | ||
reader.setEncoding(encoding); | ||
reader.on('data', function(data) { | ||
if (typeof reader.setEncoding === 'function') | ||
reader.setEncoding(encoding); | ||
reader.on(event, function(data) { | ||
var args = Array.prototype.slice.call(arguments, 1); | ||
if (data instanceof Buffer) { | ||
@@ -33,6 +40,11 @@ data = data.toString(encoding); | ||
lines.forEach(function(line, index) { | ||
self.emit('line', line); | ||
var _args = args.slice(0); | ||
_args.unshift(line); | ||
_args.unshift('line'); | ||
self.emit.apply(self, _args); | ||
}); | ||
}); | ||
var ender = function() { | ||
@@ -45,3 +57,3 @@ if (buffer.length > 0) { | ||
} | ||
reader.on('end', ender); | ||
@@ -48,0 +60,0 @@ } |
{ "name" : "carrier" | ||
, "description" : "Evented stream line reader for node.js" | ||
, "version" : "0.1.10" | ||
, "version" : "0.2.0" | ||
, "homepage" : "http://github.com/pgte/carrier" | ||
@@ -5,0 +5,0 @@ , "author" : |
Sorry, the diff of this file is not supported yet
Network access
Supply chain riskThis module accesses the network.
Found 1 instance in 1 package
9560
12
222
48
7