mirror of https://github.com/grpc/grpc-node.git
Add test for waitForReady on both implementations
This commit is contained in:
parent
fa20c5e565
commit
f03f1b52f3
|
|
@ -59,6 +59,29 @@ const serviceImpl = {
|
||||||
};
|
};
|
||||||
|
|
||||||
describe(`${anyGrpc.clientName} client -> ${anyGrpc.serverName} server`, function() {
|
describe(`${anyGrpc.clientName} client -> ${anyGrpc.serverName} server`, function() {
|
||||||
|
it('client should not wait for ready by default', function(done) {
|
||||||
|
this.timeout(15000);
|
||||||
|
const disconnectedClient = new TestServiceClient('foo.test.google.com:50051', grpc.credentials.createInsecure());
|
||||||
|
const deadline = new Date();
|
||||||
|
deadline.setSeconds(deadline.getSeconds() + 10);
|
||||||
|
disconnectedClient.unary({}, {deadline: deadline}, (error, value) =>{
|
||||||
|
assert(error);
|
||||||
|
assert.strictEqual(error.code, grpc.status.UNAVAILABLE);
|
||||||
|
done();
|
||||||
|
});
|
||||||
|
});
|
||||||
|
it('client should wait for a connection with waitForReady on', function(done) {
|
||||||
|
this.timeout(15000);
|
||||||
|
const disconnectedClient = new TestServiceClient('foo.test.google.com:50051', grpc.credentials.createInsecure());
|
||||||
|
const metadata = new grpc.Metadata({waitForReady: true});
|
||||||
|
const deadline = new Date();
|
||||||
|
deadline.setSeconds(deadline.getSeconds() + 10);
|
||||||
|
disconnectedClient.unary({}, metadata, {deadline: deadline}, (error, value) =>{
|
||||||
|
assert(error);
|
||||||
|
assert.strictEqual(error.code, grpc.status.DEADLINE_EXCEEDED);
|
||||||
|
done();
|
||||||
|
});
|
||||||
|
});
|
||||||
describe('Reconnection', function() {
|
describe('Reconnection', function() {
|
||||||
let server1;
|
let server1;
|
||||||
let server2;
|
let server2;
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue