dist/peer.js

@@ -39,10 +39,9 @@ class Peer {
     async init() {
         const self = this;
         let pipe;
-        const raw = await maybeGetAsyncProperty(self._peer.rawStream);
         this._socket = new socket_js_1.default({
-            remoteAddress: raw.remoteHost,
-            remotePort: raw.remotePort,
+            remoteAddress: self._peer.rawStream.remoteHost,
+            remotePort: self._peer.rawStream.remotePort,
             remotePublicKey: self._peer.remotePublicKey,
             async write(data, cb) {
                 if (pipe) {
@@ -91,17 +90,3 @@ class Peer {
     }
 }
 exports.default = Peer;
-async function maybeGetAsyncProperty(object) {
-    if (typeof object === "function") {
-        object = object();
-    }
-    if (isPromise(object)) {
-        object = await object;
-    }
-    return object;
-}
-function isPromise(obj) {
-    return (!!obj &&
-        (typeof obj === "object" || typeof obj === "function") &&
-        typeof obj.then === "function");
-}

src/peer.ts

@@ -101,10 +101,9 @@ export default class Peer {
   async init() {
     const self = this;
     let pipe;
-    const raw = await maybeGetAsyncProperty(self._peer.rawStream);
     this._socket = new Socket({
-      remoteAddress: raw.remoteHost,
-      remotePort: raw.remotePort,
+      remoteAddress: self._peer.rawStream.remoteHost,
+      remotePort: self._peer.rawStream.remotePort,
       remotePublicKey: self._peer.remotePublicKey,
       async write(data: any, cb: Function) {
         if (pipe) {
@@ -158,23 +157,3 @@ export default class Peer {
     await this._channel.open();
   }
 }
-
-async function maybeGetAsyncProperty(object: any) {
-  if (typeof object === "function") {
-    object = object();
-  }
-
-  if (isPromise(object)) {
-    object = await object;
-  }
-
-  return object;
-}
-
-function isPromise(obj: Promise<any>) {
-  return (
-    !!obj &&
-    (typeof obj === "object" || typeof obj === "function") &&
-    typeof obj.then === "function"
-  );
-}