|
|
|
@ -69,9 +69,6 @@ function zeroBuffer(size) { |
|
|
|
|
function emptyUnary(client, done) { |
|
|
|
|
var call = client.emptyCall({}, function(err, resp) { |
|
|
|
|
assert.ifError(err); |
|
|
|
|
}); |
|
|
|
|
call.on('status', function(status) { |
|
|
|
|
assert.strictEqual(status.code, grpc.status.OK); |
|
|
|
|
if (done) { |
|
|
|
|
done(); |
|
|
|
|
} |
|
|
|
@ -96,9 +93,6 @@ function largeUnary(client, done) { |
|
|
|
|
assert.ifError(err); |
|
|
|
|
assert.strictEqual(resp.payload.type, 'COMPRESSABLE'); |
|
|
|
|
assert.strictEqual(resp.payload.body.length, 314159); |
|
|
|
|
}); |
|
|
|
|
call.on('status', function(status) { |
|
|
|
|
assert.strictEqual(status.code, grpc.status.OK); |
|
|
|
|
if (done) { |
|
|
|
|
done(); |
|
|
|
|
} |
|
|
|
@ -115,9 +109,6 @@ function clientStreaming(client, done) { |
|
|
|
|
var call = client.streamingInputCall(function(err, resp) { |
|
|
|
|
assert.ifError(err); |
|
|
|
|
assert.strictEqual(resp.aggregated_payload_size, 74922); |
|
|
|
|
}); |
|
|
|
|
call.on('status', function(status) { |
|
|
|
|
assert.strictEqual(status.code, grpc.status.OK); |
|
|
|
|
if (done) { |
|
|
|
|
done(); |
|
|
|
|
} |
|
|
|
@ -308,9 +299,6 @@ function authTest(expected_user, scope, client, done) { |
|
|
|
|
assert.strictEqual(resp.payload.body.length, 314159); |
|
|
|
|
assert.strictEqual(resp.username, expected_user); |
|
|
|
|
assert.strictEqual(resp.oauth_scope, AUTH_SCOPE_RESPONSE); |
|
|
|
|
}); |
|
|
|
|
call.on('status', function(status) { |
|
|
|
|
assert.strictEqual(status.code, grpc.status.OK); |
|
|
|
|
if (done) { |
|
|
|
|
done(); |
|
|
|
|
} |
|
|
|
@ -344,9 +332,6 @@ function oauth2Test(expected_user, scope, per_rpc, client, done) { |
|
|
|
|
assert.ifError(err); |
|
|
|
|
assert.strictEqual(resp.username, expected_user); |
|
|
|
|
assert.strictEqual(resp.oauth_scope, AUTH_SCOPE_RESPONSE); |
|
|
|
|
}); |
|
|
|
|
call.on('status', function(status) { |
|
|
|
|
assert.strictEqual(status.code, grpc.status.OK); |
|
|
|
|
if (done) { |
|
|
|
|
done(); |
|
|
|
|
} |
|
|
|
@ -358,7 +343,6 @@ function oauth2Test(expected_user, scope, per_rpc, client, done) { |
|
|
|
|
client.updateMetadata = updateMetadata; |
|
|
|
|
makeTestCall(null, {}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
}); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|