From 3d688548a422549af12b3df1de9b560a4402f244 Mon Sep 17 00:00:00 2001
From: zygis <benetis.zygimantas@gmail.com>
Date: Fri, 12 Jul 2019 09:53:50 +0300
Subject: [PATCH] feat(tests): move away from event-stream

Connects https://github.com/pelias/pelias/issues/801
---
 package.json                 |  2 +-
 test/DocumentMapperStream.js | 15 ++++++++-------
 2 files changed, 9 insertions(+), 8 deletions(-)

diff --git a/package.json b/package.json
index a7ca323..bbcdfa6 100644
--- a/package.json
+++ b/package.json
@@ -33,7 +33,7 @@
     "through2": "^3.0.0"
   },
   "devDependencies": {
-    "event-stream": "^4.0.0",
+    "stream-mock": "^2.0.3",
     "precommit-hook": "^3.0.0",
     "proxyquire": "^2.0.0",
     "tap-spec": "^5.0.0",
diff --git a/test/DocumentMapperStream.js b/test/DocumentMapperStream.js
index a88124b..029e7e2 100644
--- a/test/DocumentMapperStream.js
+++ b/test/DocumentMapperStream.js
@@ -1,13 +1,14 @@
-var event_stream = require('event-stream');
-
 var createDocumentMapperStream = require('../DocumentMapperStream');
 var Document = require('../Document');
 
-function test_stream(input, testedStream, callback) {
-  var input_stream = event_stream.readArray(input);
-  var destination_stream = event_stream.writeArray(callback);
+const stream_mock = require('stream-mock');
 
-  input_stream.pipe(testedStream).pipe(destination_stream);
+function test_stream(input, testedStream, callback) {
+  const reader = new stream_mock.ObjectReadableMock(input);
+  const writer = new stream_mock.ObjectWritableMock();
+  writer.on('error', (e) => callback(e));
+  writer.on('finish', () => callback(null, writer.data));
+  reader.pipe(testedStream).pipe(writer);
 }
 
 module.exports.tests = {};
@@ -20,7 +21,7 @@ module.exports.tests.DocumentMapperStream = function(test) {
     test_stream([document], stream, function(err, results) {
       t.equal(results.length, 1, 'stream returns exactly one result');
       t.deepEqual(results[0], document.toESDocument(),
-                  'stream transforms Document into object ready to be inserted into Elasticsearch');
+        'stream transforms Document into object ready to be inserted into Elasticsearch');
       t.end();
     });
   });