Compare commits
3 Commits
v0.0.2-dev
...
v0.0.2-dev
Author | SHA1 | Date |
---|---|---|
semantic-release-bot | 3ff3c0a402 | |
Derrick Hammer | d489f2d9a7 | |
Derrick Hammer | b73edb9029 |
|
@ -1,3 +1,5 @@
|
||||||
|
## [0.0.2-develop.4](https://git.lumeweb.com/LumeWeb/rpc/compare/v0.0.2-develop.3...v0.0.2-develop.4) (2023-07-23)
|
||||||
|
|
||||||
## [0.0.2-develop.3](https://git.lumeweb.com/LumeWeb/rpc/compare/v0.0.2-develop.2...v0.0.2-develop.3) (2023-07-05)
|
## [0.0.2-develop.3](https://git.lumeweb.com/LumeWeb/rpc/compare/v0.0.2-develop.2...v0.0.2-develop.3) (2023-07-05)
|
||||||
|
|
||||||
## [0.0.2-develop.2](https://git.lumeweb.com/LumeWeb/rpc/compare/v0.0.2-develop.1...v0.0.2-develop.2) (2023-07-04)
|
## [0.0.2-develop.2](https://git.lumeweb.com/LumeWeb/rpc/compare/v0.0.2-develop.1...v0.0.2-develop.2) (2023-07-04)
|
||||||
|
|
|
@ -1,12 +1,12 @@
|
||||||
{
|
{
|
||||||
"name": "@lumeweb/rpc",
|
"name": "@lumeweb/rpc",
|
||||||
"version": "0.0.2-develop.3",
|
"version": "0.0.2-develop.4",
|
||||||
"lockfileVersion": 3,
|
"lockfileVersion": 3,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"name": "@lumeweb/rpc",
|
"name": "@lumeweb/rpc",
|
||||||
"version": "0.0.2-develop.3",
|
"version": "0.0.2-develop.4",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"compact-encoding": "2.12.0",
|
"compact-encoding": "2.12.0",
|
||||||
"protomux-rpc": "1.4.1"
|
"protomux-rpc": "1.4.1"
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
{
|
{
|
||||||
"name": "@lumeweb/rpc",
|
"name": "@lumeweb/rpc",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"version": "0.0.2-develop.3",
|
"version": "0.0.2-develop.4",
|
||||||
"main": "lib/index.js",
|
"main": "lib/index.js",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
|
|
22
src/index.ts
22
src/index.ts
|
@ -17,9 +17,25 @@ export default class RPC extends ProtomuxRPC {
|
||||||
...options,
|
...options,
|
||||||
};
|
};
|
||||||
super(stream, options);
|
super(stream, options);
|
||||||
this._ready = new Promise((resolve) => {
|
|
||||||
// @ts-ignore
|
this._ready = new Promise((resolve, reject) => {
|
||||||
this.on("open", resolve);
|
stream.on("open", onopen);
|
||||||
|
stream.on("destroy", ondestroy);
|
||||||
|
|
||||||
|
function onopen(handshake) {
|
||||||
|
removeListener();
|
||||||
|
resolve(handshake);
|
||||||
|
}
|
||||||
|
|
||||||
|
function ondestroy() {
|
||||||
|
removeListener();
|
||||||
|
reject(new Error("Client could not connect"));
|
||||||
|
}
|
||||||
|
|
||||||
|
function removeListener() {
|
||||||
|
stream.off("open", onopen);
|
||||||
|
stream.off("destroy", ondestroy);
|
||||||
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue