mirror of https://github.com/grpc/grpc-node.git
grpc-js: Restore socket disconnect handling
This commit is contained in:
parent
f0c58f79c5
commit
848e00e54c
|
@ -1,6 +1,6 @@
|
||||||
{
|
{
|
||||||
"name": "@grpc/grpc-js",
|
"name": "@grpc/grpc-js",
|
||||||
"version": "1.12.2",
|
"version": "1.12.3",
|
||||||
"description": "gRPC Library for Node - pure JS implementation",
|
"description": "gRPC Library for Node - pure JS implementation",
|
||||||
"homepage": "https://grpc.io/",
|
"homepage": "https://grpc.io/",
|
||||||
"repository": "https://github.com/grpc/grpc-node/tree/master/packages/grpc-js",
|
"repository": "https://github.com/grpc/grpc-node/tree/master/packages/grpc-js",
|
||||||
|
|
|
@ -227,6 +227,11 @@ class Http2Transport implements Transport {
|
||||||
this.handleDisconnect();
|
this.handleDisconnect();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
session.socket.once('close', () => {
|
||||||
|
this.trace('connection closed');
|
||||||
|
this.handleDisconnect();
|
||||||
|
});
|
||||||
|
|
||||||
if (logging.isTracerEnabled(TRACER_NAME)) {
|
if (logging.isTracerEnabled(TRACER_NAME)) {
|
||||||
session.on('remoteSettings', (settings: http2.Settings) => {
|
session.on('remoteSettings', (settings: http2.Settings) => {
|
||||||
this.trace(
|
this.trace(
|
||||||
|
|
Loading…
Reference in New Issue