diff --git a/lib/read-stream.js b/lib/read-stream.js index 003da5da..b8241d7b 100644 --- a/lib/read-stream.js +++ b/lib/read-stream.js @@ -13,10 +13,11 @@ var Readable = require('readable-stream').Readable , defaultOptions = { keys: true, values: true } - , makeKeyValueData = function (key, value) { + , makeKeyValueData = function (key, value, extra) { return { key: util.decodeKey(key, this._options) , value: util.decodeValue(value, this._options) + , extra: extra } } , makeKeyData = function (key) { @@ -78,7 +79,7 @@ ReadStream.prototype._read = function read () { if (self._destroyed) return - self._iterator.next(function(err, key, value) { + self._iterator.next(function(err, key, value, extra) { if (err || (key === undefined && value === undefined)) { if (!err && !self._destroyed) self.push(null) @@ -86,7 +87,7 @@ ReadStream.prototype._read = function read () { } try { - value = self._makeData(key, value) + value = self._makeData(key, value, extra) } catch (e) { return self._cleanup(new EncodingError(e)) }