From 68a76aa185590e4e32553f61dbfc0c22cdbde632 Mon Sep 17 00:00:00 2001
From: Ben Irvin <ben@innerdvations.com>
Date: Mon, 21 Nov 2022 14:15:30 +0100
Subject: [PATCH] remove stream-mock

---
 .../lib/engine/__tests__/engine.test.ts             | 13 +++++++------
 packages/core/data-transfer/package.json            |  1 -
 yarn.lock                                           |  5 -----
 3 files changed, 7 insertions(+), 12 deletions(-)

diff --git a/packages/core/data-transfer/lib/engine/__tests__/engine.test.ts b/packages/core/data-transfer/lib/engine/__tests__/engine.test.ts
index 7c1d1a664f..2d279220ec 100644
--- a/packages/core/data-transfer/lib/engine/__tests__/engine.test.ts
+++ b/packages/core/data-transfer/lib/engine/__tests__/engine.test.ts
@@ -1,4 +1,4 @@
-import { ObjectWritableMock, ObjectReadableMock } from 'stream-mock';
+import { Readable, Writable } from 'stream-chain';
 import { createTransferEngine } from '..';
 import {
   IDestinationProvider,
@@ -10,16 +10,17 @@ import {
 const providerStages = ['bootstrap', 'close'];
 
 const getMockSourceStream = (data: Iterable<any> = ['foo', 'bar']) => {
-  const stream = new ObjectReadableMock(data).on('close', () => {
-    stream.destroy();
-  });
+  const stream = Readable.from(data);
 
   return stream;
 };
 
 const getMockDestinationStream = () => {
-  const stream = new ObjectWritableMock().on('close', () => {
-    stream.destroy();
+  const stream = new Writable({
+    objectMode: true,
+    write(chunk, encoding, callback) {
+      callback();
+    },
   });
   return stream;
 };
diff --git a/packages/core/data-transfer/package.json b/packages/core/data-transfer/package.json
index cc0eedd1f9..f54f4c3cf4 100644
--- a/packages/core/data-transfer/package.json
+++ b/packages/core/data-transfer/package.json
@@ -55,7 +55,6 @@
     "@types/stream-json": "1.7.2",
     "@types/tar": "6.1.3",
     "rimraf": "3.0.2",
-    "stream-mock": "2.0.5",
     "typescript": "4.6.2"
   },
   "engines": {
diff --git a/yarn.lock b/yarn.lock
index 3b9fc525dc..e076421656 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -20830,11 +20830,6 @@ stream-json@1.7.4:
   dependencies:
     stream-chain "^2.2.5"
 
-stream-mock@2.0.5:
-  version "2.0.5"
-  resolved "https://registry.yarnpkg.com/stream-mock/-/stream-mock-2.0.5.tgz#c99d24bd6dbb0eaa57cf6ffefdb064150747826e"
-  integrity sha512-dx9skT8QYjwLsal+MhGHr4UtgS49brw851C/oTixmhCi4Ip+/qnZmhV1qOcznYYAED6gYKmKea+jjza4/wjpSg==
-
 stream-shift@^1.0.0:
   version "1.0.1"
   resolved "https://registry.yarnpkg.com/stream-shift/-/stream-shift-1.0.1.tgz#d7088281559ab2778424279b0877da3c392d5a3d"