summaryrefslogtreecommitdiff
path: root/test/parallel/test-stream-transform-split-objectmode.js
diff options
context:
space:
mode:
Diffstat (limited to 'test/parallel/test-stream-transform-split-objectmode.js')
-rw-r--r--test/parallel/test-stream-transform-split-objectmode.js13
1 files changed, 7 insertions, 6 deletions
diff --git a/test/parallel/test-stream-transform-split-objectmode.js b/test/parallel/test-stream-transform-split-objectmode.js
index df10ed1b65..24833ece05 100644
--- a/test/parallel/test-stream-transform-split-objectmode.js
+++ b/test/parallel/test-stream-transform-split-objectmode.js
@@ -1,3 +1,4 @@
+'use strict';
var common = require('../common');
var assert = require('assert');
@@ -10,19 +11,19 @@ assert(!parser._writableState.objectMode);
assert(parser._readableState.highWaterMark === 16);
assert(parser._writableState.highWaterMark === (16 * 1024));
-parser._transform = function (chunk, enc, callback) {
+parser._transform = function(chunk, enc, callback) {
callback(null, { val : chunk[0] });
};
var parsed;
-parser.on('data', function (obj) {
+parser.on('data', function(obj) {
parsed = obj;
});
parser.end(new Buffer([42]));
-process.on('exit', function () {
+process.on('exit', function() {
assert(parsed.val === 42);
});
@@ -34,18 +35,18 @@ assert(serializer._writableState.objectMode);
assert(serializer._readableState.highWaterMark === (16 * 1024));
assert(serializer._writableState.highWaterMark === 16);
-serializer._transform = function (obj, _, callback) {
+serializer._transform = function(obj, _, callback) {
callback(null, new Buffer([obj.val]));
};
var serialized;
-serializer.on('data', function (chunk) {
+serializer.on('data', function(chunk) {
serialized = chunk;
});
serializer.write({ val : 42 });
-process.on('exit', function () {
+process.on('exit', function() {
assert(serialized[0] === 42);
});