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: deadline filter: reject promise if call ends

This commit is contained in:
murgatroid99 2019-03-07 11:02:20 -08:00
parent 669a6ef3a4
commit d77da26021
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
packages/grpc-js/src/deadline-filter.ts
View File

@ -62,7 +62,13 @@ export class DeadlineFilter extends BaseFilter implements Filter {
'connectivityStateChanged', handleStateChange);
}
};
const handleStatus = () => {
reject(new Error('Call ended'));
this.channel.removeListener(
'connectivityStateChanged', handleStateChange);
};
this.channel.on('connectivityStateChanged', handleStateChange);
this.callStream.once('status', handleStatus);
}
})
.then((finalMetadata: Metadata) => {