From a7535f43929059ed530f18e6a5868458ba85ea0c Mon Sep 17 00:00:00 2001
From: Moon Man <moon@eth.co>
Date: Sun, 28 Jan 2024 10:12:30 -0500
Subject: [PATCH] maybe works now?

---
 dist/main.d.ts |  5 ++---
 dist/main.js   |  8 ++------
 src/main.ts    | 10 ++--------
 3 files changed, 6 insertions(+), 17 deletions(-)

diff --git a/dist/main.d.ts b/dist/main.d.ts
index ba780fe..dedf6f0 100644
--- a/dist/main.d.ts
+++ b/dist/main.d.ts
@@ -4,8 +4,7 @@ import { Duplex } from "node:stream";
 type WriteCallback = (error: Error | null | undefined) => void;
 export declare class Port extends Duplex {
     constructor();
-    read(): any;
-    write(obj: any, encodingOrCallback?: BufferEncoding | WriteCallback, callback?: WriteCallback | undefined): boolean;
-    _final(): void;
+    _read(): any;
+    _write(obj: any, encodingOrCallback?: BufferEncoding | WriteCallback, callback?: WriteCallback | undefined): boolean;
 }
 export {};
diff --git a/dist/main.js b/dist/main.js
index 1bce387..99bf54b 100644
--- a/dist/main.js
+++ b/dist/main.js
@@ -7,7 +7,7 @@ export class Port extends Duplex {
     constructor() {
         super({ objectMode: true });
     }
-    read() {
+    _read() {
         const lenBytes = process.stdin.read(4);
         if (lenBytes) {
             const termLen = bert.bytesToInt(lenBytes, 4, true);
@@ -23,7 +23,7 @@ export class Port extends Duplex {
         else
             return null;
     }
-    write(obj, encodingOrCallback, callback) {
+    _write(obj, encodingOrCallback, callback) {
         const actualCallback = callback || typeof encodingOrCallback === "function" ? encodingOrCallback : undefined;
         try {
             const term = bert.encode(obj, true);
@@ -37,8 +37,4 @@ export class Port extends Duplex {
             return false;
         }
     }
-    // When all the data is done passing, it stops.
-    _final() {
-        this.push(null);
-    }
 }
diff --git a/src/main.ts b/src/main.ts
index e5efda4..b34b0f4 100644
--- a/src/main.ts
+++ b/src/main.ts
@@ -13,7 +13,7 @@ export class Port extends Duplex {
         super({ objectMode: true });
     }
 
-    read() {
+    _read() {
         const lenBytes = process.stdin.read(4);
         if (lenBytes) {
             const termLen = bert.bytesToInt(lenBytes, 4, true);
@@ -30,7 +30,7 @@ export class Port extends Duplex {
         else return null;
     }
 
-    write(obj: any, encodingOrCallback?: BufferEncoding | WriteCallback, callback?: WriteCallback | undefined) {
+    _write(obj: any, encodingOrCallback?: BufferEncoding | WriteCallback, callback?: WriteCallback | undefined) {
         const actualCallback: any = callback || typeof encodingOrCallback === "function" ? encodingOrCallback : undefined;
         
         try {
@@ -46,10 +46,4 @@ export class Port extends Duplex {
             return false;
         }
     }
-
-    // When all the data is done passing, it stops.
-    _final() {
-        this.push(null);
-    }
 }
-