fix(core): update

test/test.streamfunction.ts

@@ -27,8 +27,7 @@ tap.test('should handle a read stream', async (tools) => {
       streamEndFunction: async (tools) => {
         tools.push(null);
       },
-    }),
-    smartstream.cleanPipe(),
+    })
   ]);
   // await streamWrapper.run();
 });