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

Merge pull request #1905 from murgatroid99/grpc-js-xds_interop_improvements 

grpc-js-xds: fix use of splice in interop test code
This commit is contained in:
Michael Lumish 2021-09-28 15:48:29 -07:00 committed by GitHub
parent 255618ede8 1ae04af7ba
commit 5e8f5faeab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
packages/grpc-js-xds/interop/xds-interop-client.ts
View File

@ -130,6 +130,13 @@ class CallStatsTracker {
private subscribers: CallSubscriber[] = [];
private removeSubscriber(subscriber: CallSubscriber) {
const index = this.subscribers.indexOf(subscriber);
if (index >= 0) {
this.subscribers.splice(index, 1);
}
}
getCallStats(callCount: number, timeoutSec: number): Promise<LoadBalancerStatsResponse> {
return new Promise((resolve, reject) => {
let finished = false;
@ -142,7 +149,7 @@ class CallStatsTracker {
setTimeout(() => {
if (!finished) {
finished = true;
this.subscribers.splice(this.subscribers.indexOf(subscriber), 1);
this.removeSubscriber(subscriber);
resolve(subscriber.getFinalStats());
}
}, timeoutSec * 1000)
@ -155,7 +162,7 @@ class CallStatsTracker {
for (const subscriber of callSubscribers) {
subscriber.addCallStarted();
if (!subscriber.needsMoreCalls()) {
this.subscribers.splice(this.subscribers.indexOf(subscriber), 1);
this.removeSubscriber(subscriber);
}
}
return {