*Update dist
This commit is contained in:
parent
5c666d38c0
commit
6099a6c4f6
|
@ -39,9 +39,10 @@ class Peer {
|
||||||
async init() {
|
async init() {
|
||||||
const self = this;
|
const self = this;
|
||||||
let pipe;
|
let pipe;
|
||||||
|
const raw = await maybeGetAsyncProperty(self._peer.rawStream);
|
||||||
this._socket = new socket_js_1.default({
|
this._socket = new socket_js_1.default({
|
||||||
remoteAddress: self._peer.rawStream.remoteHost,
|
remoteAddress: raw.remoteHost,
|
||||||
remotePort: self._peer.rawStream.remotePort,
|
remotePort: raw.remotePort,
|
||||||
remotePublicKey: self._peer.remotePublicKey,
|
remotePublicKey: self._peer.remotePublicKey,
|
||||||
async write(data, cb) {
|
async write(data, cb) {
|
||||||
if (pipe) {
|
if (pipe) {
|
||||||
|
@ -90,3 +91,17 @@ class Peer {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
exports.default = 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");
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue