remove a layer of indirection

replit · Oct 24, 2024 · e3446de · e3446de
1 parent 272d0a1
commit e3446de
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 8 deletions.
diff --git a/tests/index.test.ts b/tests/index.test.ts
@@ -326,7 +326,7 @@ describe(
     );
 
     test('doesnt miss large output from fast commands',
-      { repeats: 10 },
+      { repeats: 50 },
       () =>
         new Promise<void>((done) => {
           const payload = `hello`.repeat(4096);

diff --git a/wrapper.ts b/wrapper.ts
@@ -71,12 +71,12 @@ export class Pty {
     this.#fd = this.#pty.takeFd();
 
     this.#socket = new ReadStream(this.#fd);
-    const userFacingRead = new PassThrough();
-    const userFacingWrite = new PassThrough();
-    this.#socket.pipe(userFacingRead);
-    userFacingWrite.pipe(this.#socket);
-    this.read = userFacingRead;
-    this.write = userFacingWrite;
+    // const userFacingRead = new PassThrough();
+    // const userFacingWrite = new PassThrough();
+    // this.#socket.pipe(userFacingRead);
+    // userFacingWrite.pipe(this.#socket);
+    this.read = this.#socket;
+    this.write = this.#socket;
 
     // catch end events
     const handleClose = () => {
@@ -88,7 +88,6 @@ export class Pty {
       exitResult.then((result) => {
         realExit(result.error, result.code)
       });
-      userFacingRead.end();
     };
     this.#socket.on('close', handleClose);