grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merged node_test_fixes

This commit is contained in:
murgatroid99 2015-08-20 11:28:20 -07:00
parent 402ebf88d9 3bd3e4094f
commit 0695ded28e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/client.js
View File

@ -283,7 +283,9 @@ function makeUnaryRequestFunction(method, serialize, deserialize) {
} }
var client_batch = {}; var client_batch = {};
var message = serialize(argument); var message = serialize(argument);
message.grpcWriteFlags = options.flags; if (options) {
message.grpcWriteFlags = options.flags;
}
client_batch[grpc.opType.SEND_INITIAL_METADATA] = client_batch[grpc.opType.SEND_INITIAL_METADATA] =
metadata._getCoreRepresentation(); metadata._getCoreRepresentation();
client_batch[grpc.opType.SEND_MESSAGE] = message; client_batch[grpc.opType.SEND_MESSAGE] = message;
@ -429,7 +431,9 @@ function makeServerStreamRequestFunction(method, serialize, deserialize) {
} }
var start_batch = {}; var start_batch = {};
var message = serialize(argument); var message = serialize(argument);
message.grpcWriteFlags = options.flags; if (options) {
message.grpcWriteFlags = options.flags;
}
start_batch[grpc.opType.SEND_INITIAL_METADATA] = start_batch[grpc.opType.SEND_INITIAL_METADATA] =
metadata._getCoreRepresentation(); metadata._getCoreRepresentation();
start_batch[grpc.opType.RECV_INITIAL_METADATA] = true; start_batch[grpc.opType.RECV_INITIAL_METADATA] = true;