|
|
@ -784,7 +784,8 @@ describe('Other conditions', function() { |
|
|
|
client.clientStream(function(err, value) { |
|
|
|
client.clientStream(function(err, value) { |
|
|
|
try { |
|
|
|
try { |
|
|
|
assert(err); |
|
|
|
assert(err); |
|
|
|
assert.strictEqual(err.code, grpc.status.DEADLINE_EXCEEDED); |
|
|
|
assert(err.code === grpc.status.DEADLINE_EXCEEDED || |
|
|
|
|
|
|
|
err.code === grpc.status.INTERNAL); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
callback(err, value); |
|
|
|
callback(err, value); |
|
|
|
done(); |
|
|
|
done(); |
|
|
@ -809,7 +810,8 @@ describe('Other conditions', function() { |
|
|
|
null, {parent: parent, propagate_flags: deadline_flags}); |
|
|
|
null, {parent: parent, propagate_flags: deadline_flags}); |
|
|
|
child.on('error', function(err) { |
|
|
|
child.on('error', function(err) { |
|
|
|
assert(err); |
|
|
|
assert(err); |
|
|
|
assert.strictEqual(err.code, grpc.status.DEADLINE_EXCEEDED); |
|
|
|
assert(err.code === grpc.status.DEADLINE_EXCEEDED || |
|
|
|
|
|
|
|
err.code === grpc.status.INTERNAL); |
|
|
|
done(); |
|
|
|
done(); |
|
|
|
}); |
|
|
|
}); |
|
|
|
}; |
|
|
|
}; |
|
|
|