Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -1575,6 +1575,7 @@ export class AssetServiceClient {
this._terminated = true;
stub.close();
void this.operationsClient.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -240,10 +240,9 @@ describe('v1.AssetServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -256,10 +255,9 @@ describe('v1.AssetServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1553,6 +1553,7 @@ export class AssetServiceClient {
this._terminated = true;
stub.close();
void this.operationsClient.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -229,10 +229,9 @@ describe('v1.AssetServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -245,10 +244,9 @@ describe('v1.AssetServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1235,6 +1235,7 @@ export class BigQueryStorageClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -236,10 +236,9 @@ describe('v1beta1.BigQueryStorageClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -252,10 +251,9 @@ describe('v1beta1.BigQueryStorageClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1213,6 +1213,7 @@ export class BigQueryStorageClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -225,10 +225,9 @@ describe('v1beta1.BigQueryStorageClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -241,10 +240,9 @@ describe('v1beta1.BigQueryStorageClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1503,6 +1503,7 @@ export class DatasetServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1542,6 +1542,7 @@ export class JobServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1050,6 +1050,7 @@ export class ModelServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -532,6 +532,7 @@ export class ProjectServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1335,6 +1335,7 @@ export class RoutineServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -653,6 +653,7 @@ export class RowAccessPolicyServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1359,6 +1359,7 @@ export class TableServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -271,10 +271,9 @@ describe('v2.DatasetServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -287,10 +286,9 @@ describe('v2.DatasetServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -269,10 +269,9 @@ describe('v2.JobServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -285,10 +284,9 @@ describe('v2.JobServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -271,10 +271,9 @@ describe('v2.ModelServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -287,10 +286,9 @@ describe('v2.ModelServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -208,10 +208,9 @@ describe('v2.ProjectServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -224,10 +223,9 @@ describe('v2.ProjectServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -271,10 +271,9 @@ describe('v2.RoutineServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -287,10 +286,9 @@ describe('v2.RoutineServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -284,10 +284,9 @@ describe('v2.RowAccessPolicyServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -301,10 +300,9 @@ describe('v2.RowAccessPolicyServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -271,10 +271,9 @@ describe('v2.TableServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has close method for the non-initialized client', done => {
Expand All @@ -287,10 +286,9 @@ describe('v2.TableServiceClient', () => {
.close()
.then(() => {
done();
return;
})
.catch(err => {
throw err;
});
.catch(done);
});

it('has getProjectId method', async () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1481,6 +1481,7 @@ export class DatasetServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1520,6 +1520,7 @@ export class JobServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1028,6 +1028,7 @@ export class ModelServiceClient {
this._log.info('ending gRPC channel');
this._terminated = true;
stub.close();
return;
});
}
return Promise.resolve();
Expand Down
Loading
Loading