archive-gh-me/grpc-node
1
0
Fork 0
mirror of https://github.com/grpc/grpc-node.git synced 2025-12-08 18:23:54 +00:00
Code Issues Projects Releases Wiki Activity

grpc-js-core: change rstStream to close

Browse Source
This commit is contained in:
Kelvin Jin 2017-12-22 15:30:37 -08:00
parent 1d1aa273f0
commit 063e11162e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -9,7 +9,7 @@ import {FilterStackFactory} from './filter-stack';
import {Metadata} from './metadata';
import {ObjectDuplex} from './object-stream';
const {HTTP2_HEADER_STATUS, HTTP2_HEADER_CONTENT_TYPE} = http2.constants;
const {HTTP2_HEADER_STATUS, HTTP2_HEADER_CONTENT_TYPE, NGHTTP2_CANCEL} = http2.constants;
export type Deadline = Date | number;
@ -156,7 +156,7 @@ export class Http2CallStream extends Duplex implements CallStream {
attachHttp2Stream(stream: http2.ClientHttp2Stream): void {
if (this.finalStatus !== null) {
stream.rstWithCancel();
(stream as any).close(NGHTTP2_CANCEL);
} else {
this.http2Stream = stream;
stream.on('response', (headers, flags) => {
@ -328,7 +328,7 @@ export class Http2CallStream extends Duplex implements CallStream {
if (this.http2Stream !== null && !this.http2Stream.destroyed) {
/* TODO(murgatroid99): Determine if we want to send different RST_STREAM
* codes based on the status code */
this.http2Stream.rstWithCancel();
(this.http2Stream as any).close(NGHTTP2_CANCEL);
}
}