diff options
author | murgatroid99 <mlumish@google.com> | 2016-06-23 14:30:40 -0700 |
---|---|---|
committer | murgatroid99 <mlumish@google.com> | 2016-06-23 14:30:40 -0700 |
commit | 67e2525892c57be3b20d517810c25a5e861cb515 (patch) | |
tree | 4b135e7874041f38df9fe5ef4a5dad6232696992 /src/ruby/pb | |
parent | 674f55a9ac7536b001abcac73db89e4260e935e2 (diff) |
Fix handling of one error in bidi calls, and one interop server method
Diffstat (limited to 'src/ruby/pb')
-rwxr-xr-x | src/ruby/pb/test/server.rb | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/ruby/pb/test/server.rb b/src/ruby/pb/test/server.rb index 914c7cc79d..088f281dc4 100755 --- a/src/ruby/pb/test/server.rb +++ b/src/ruby/pb/test/server.rb @@ -188,11 +188,13 @@ class TestTarget < Grpc::Testing::TestService::Service begin GRPC.logger.info('interop-server: started receiving') reqs.each do |req| - resp_size = req.response_parameters[0].size - GRPC.logger.info("read a req, response size is #{resp_size}") - resp = cls.new(payload: Payload.new(type: req.response_type, - body: nulls(resp_size))) - q.push(resp) + req.response_parameters.each do |params| + resp_size = params.size + GRPC.logger.info("read a req, response size is #{resp_size}") + resp = cls.new(payload: Payload.new(type: req.response_type, + body: nulls(resp_size))) + q.push(resp) + end end GRPC.logger.info('interop-server: finished receiving') q.push(self) |