diff --git a/src/index.ts b/src/index.ts
index 92e5467..25d8ee5 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -85,4 +85,9 @@ export default class HyperTransportPeer extends BasePeer {
   sendMessage(message: Uint8Array): void {
     this._pipe.send(message);
   }
+
+  end(): void {
+    this._pipe.end();
+    this._socket.end();
+  }
 }