		@@ -56,4 +56,4 @@ "use strict";
		this.streams.forEach(function (stream, sid) {
		stream.messages.close(new Error("underlining connection closed"));
		stream.headers.close(new Error("underlining connection closed"));
		stream.messages.close(status_1.ConnectionLostError);
		stream.headers.close(status_1.ConnectionLostError);
		});
		@@ -60,0 +60,0 @@ this.streams.clear();

lib/index.d.ts

		@@ -6,1 +6,2 @@ export { ServiceFactory, RpcMeta, ServiceMeta } from "./types";
		export { StreamReader, StreamController } from "./stream";
		export { ConnectionLostError } from "./status";

lib/index.js

		@@ -12,1 +12,3 @@ "use strict";
		exports.StreamController = stream_1.StreamController;
		var status_1 = require("./status");
		exports.ConnectionLostError = status_1.ConnectionLostError;

lib/status.d.ts

		@@ -20,1 +20,2 @@ export declare class StatusCode {
		}
		export declare const ConnectionLostError: Error;

lib/status.js

		@@ -94,1 +94,2 @@ "use strict";
		exports.StatusCode = StatusCode;
		exports.ConnectionLostError = new Error("underlining connection closed");

lib/ws/Server.js

		@@ -59,3 +59,3 @@ "use strict";
		this.descriptors.set(name, { meta: meta, factory: factory });
		console.log("add rpc [" + name + "], methods:", meta);
		// console.log(`add rpc [${name}], methods:`, meta);
		};
		@@ -62,0 +62,0 @@ return Server;

lib/wsgrpc.d.ts

		@@ -8,1 +8,2 @@ /**
		export { StreamReader, StreamController } from "./stream";
		export { ConnectionLostError } from "./status";

lib/wsgrpc.js

		@@ -13,1 +13,3 @@ "use strict";
		exports.StreamController = stream_1.StreamController;
		var status_1 = require("./status");
		exports.ConnectionLostError = status_1.ConnectionLostError;

package.json

TODO.txt

wsgrpc - npm Package Compare versions

New alerts