*Bug fix pushRemote
This commit is contained in:
parent
ab4632b644
commit
54904ab1ad
6
index.js
6
index.js
|
@ -638,6 +638,10 @@ module.exports = class Protomux {
|
||||||
|
|
||||||
this._remote[rid] = { state, pending: null, session: null };
|
this._remote[rid] = { state, pending: null, session: null };
|
||||||
|
|
||||||
|
if (this._slave) {
|
||||||
|
await this.pushRemote(remoteId);
|
||||||
|
}
|
||||||
|
|
||||||
session._remoteId = remoteId;
|
session._remoteId = remoteId;
|
||||||
session._fullyOpen();
|
session._fullyOpen();
|
||||||
return;
|
return;
|
||||||
|
@ -658,7 +662,7 @@ module.exports = class Protomux {
|
||||||
info.incoming.push(remoteId);
|
info.incoming.push(remoteId);
|
||||||
|
|
||||||
if (this._slave) {
|
if (this._slave) {
|
||||||
await this.pushRemotes();
|
await this.pushRemote(remoteId);
|
||||||
}
|
}
|
||||||
|
|
||||||
this._requestSession(protocol, id, info).catch(this._safeDestroyBound);
|
this._requestSession(protocol, id, info).catch(this._safeDestroyBound);
|
||||||
|
|
Reference in New Issue