diff options
| author |  murgatroid99 <mlumish@google.com> | 2015-08-20 11:44:52 -0700 |
|---|---|---|
| committer | murgatroid99 <mlumish@google.com> | 2015-08-20 11:44:52 -0700 |
| commit | f441b3fdf2fb85076380502dd50025246e76130e (patch) | |
| tree | 3ddf0950fb58ae825b6c091888d71e423f183baa /src/node/src/client.js | |
| parent | 5bb9fc178913a68bcb1a021a2d820632f9b0d8c0 (diff) | |
Fixed test and lint errors
Diffstat (limited to 'src/node/src/client.js')
| -rw-r--r-- | src/node/src/client.js | 20 |
1 files changed, 12 insertions, 8 deletions
diff --git a/src/node/src/client.js b/src/node/src/client.js index b90af42054..e1bed3512e 100644 --- a/src/node/src/client.js +++ b/src/node/src/client.js @@ -294,12 +294,13 @@ function makeUnaryRequestFunction(method, serialize, deserialize) { client_batch[grpc.opType.RECV_MESSAGE] = true; client_batch[grpc.opType.RECV_STATUS_ON_CLIENT] = true; call.startBatch(client_batch, function(err, response) { + response.status.metadata = Metadata._fromCoreRepresentation( + response.status.metadata); emitter.emit('status', response.status); if (response.status.code !== grpc.status.OK) { var error = new Error(response.status.details); error.code = response.status.code; - error.metadata = Metadata._fromCoreRepresentation( - response.status.metadata); + error.metadata = response.status.metadata; callback(error); return; } else { @@ -371,12 +372,13 @@ function makeClientStreamRequestFunction(method, serialize, deserialize) { client_batch[grpc.opType.RECV_MESSAGE] = true; client_batch[grpc.opType.RECV_STATUS_ON_CLIENT] = true; call.startBatch(client_batch, function(err, response) { + response.status.metadata = Metadata._fromCoreRepresentation( + response.status.metadata); stream.emit('status', response.status); if (response.status.code !== grpc.status.OK) { var error = new Error(response.status.details); error.code = response.status.code; - error.metadata = Metadata._fromCoreRepresentation( - response.status.metadata); + error.metadata = response.status.metadata; callback(error); return; } else { @@ -451,12 +453,13 @@ function makeServerStreamRequestFunction(method, serialize, deserialize) { var status_batch = {}; status_batch[grpc.opType.RECV_STATUS_ON_CLIENT] = true; call.startBatch(status_batch, function(err, response) { + response.status.metadata = Metadata._fromCoreRepresentation( + response.status.metadata); stream.emit('status', response.status); if (response.status.code !== grpc.status.OK) { var error = new Error(response.status.details); error.code = response.status.code; - error.metadata = Metadata._fromCoreRepresentation( - response.status.metadata); + error.metadata = response.status.metadata; stream.emit('error', error); return; } else { @@ -522,12 +525,13 @@ function makeBidiStreamRequestFunction(method, serialize, deserialize) { var status_batch = {}; status_batch[grpc.opType.RECV_STATUS_ON_CLIENT] = true; call.startBatch(status_batch, function(err, response) { + response.status.metadata = Metadata._fromCoreRepresentation( + response.status.metadata); stream.emit('status', response.status); if (response.status.code !== grpc.status.OK) { var error = new Error(response.status.details); error.code = response.status.code; - error.metadata = Metadata._fromCoreRepresentation( - response.status.metadata); + error.metadata = response.status.metadata; stream.emit('error', error); return; } else { |