grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

grpc-js: Handle errors thrown by writing to http2 stream

This commit is contained in:
Michael Lumish 2021-08-06 11:53:48 -07:00
parent 4d696376e9
commit ce2765f7fb
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
packages/grpc-js/src/call-stream.ts
View File

@ -637,7 +637,15 @@ export class Http2CallStream implements Call {
this.pendingWrite.length + this.pendingWrite.length +
' (deferred)' ' (deferred)'
); );
stream.write(this.pendingWrite, this.pendingWriteCallback); try {
stream.write(this.pendingWrite, this.pendingWriteCallback);
} catch (error) {
this.endCall({
code: Status.UNAVAILABLE,
details: `Write failed with error ${error.message}`,
metadata: new Metadata()
});
}
} }
this.maybeCloseWrites(); this.maybeCloseWrites();
} }
@ -762,7 +770,15 @@ export class Http2CallStream implements Call {
this.pendingWriteCallback = cb; this.pendingWriteCallback = cb;
} else { } else {
this.trace('sending data chunk of length ' + message.message.length); this.trace('sending data chunk of length ' + message.message.length);
this.http2Stream.write(message.message, cb); try {
this.http2Stream.write(message.message, cb);
} catch (error) {
this.endCall({
code: Status.UNAVAILABLE,
details: `Write failed with error ${error.message}`,
metadata: new Metadata()
});
}
this.maybeCloseWrites(); this.maybeCloseWrites();
} }
}, this.handleFilterError.bind(this)); }, this.handleFilterError.bind(this));