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

Also use original call metadata

This commit is contained in:
murgatroid99 2019-09-30 15:56:15 -07:00
parent c7d086bfb4
commit 4e7f4dff17
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
packages/grpc-js/src/channel.ts
View File

@ -203,7 +203,7 @@ export class ChannelImplementation implements Channel {
/* If the subchannel disconnects between calling pick and getting /* If the subchannel disconnects between calling pick and getting
* the filter stack metadata, the call will end with an error. */ * the filter stack metadata, the call will end with an error. */
callStream.filterStack callStream.filterStack
.sendMetadata(Promise.resolve(new Metadata())) .sendMetadata(Promise.resolve(callMetadata))
.then( .then(
finalMetadata => { finalMetadata => {
if ( if (

4
packages/grpc-js/test/test-server-deadlines.ts
View File

@ -83,9 +83,9 @@ describe('Server deadlines', () => {
metadata, metadata,
{}, {},
(error: any, response: any) => { (error: any, response: any) => {
assert(error);
assert.strictEqual(error.code, grpc.status.DEADLINE_EXCEEDED); assert.strictEqual(error.code, grpc.status.DEADLINE_EXCEEDED);
assert.strictEqual(error.details, 'Deadline exceeded'); assert.strictEqual(error.details, 'Deadline exceeded');
assert.strictEqual(error.message, 'Deadline exceeded');
done(); done();
} }
); );
@ -108,9 +108,9 @@ describe('Server deadlines', () => {
metadata, metadata,
{}, {},
(error: any, response: any) => { (error: any, response: any) => {
assert(error);
assert.strictEqual(error.code, grpc.status.OUT_OF_RANGE); assert.strictEqual(error.code, grpc.status.OUT_OF_RANGE);
assert.strictEqual(error.details, 'Invalid deadline'); assert.strictEqual(error.details, 'Invalid deadline');
assert.strictEqual(error.message, 'Invalid deadline');
done(); done();
} }
); );