|
|
@ -188,7 +188,6 @@ module GRPC |
|
|
|
# marshalled. |
|
|
|
# marshalled. |
|
|
|
def remote_send(req, marshalled = false) |
|
|
|
def remote_send(req, marshalled = false) |
|
|
|
# TODO(murgatroid99): ensure metadata was sent |
|
|
|
# TODO(murgatroid99): ensure metadata was sent |
|
|
|
GRPC.logger.debug("sending #{req}, marshalled? #{marshalled}") |
|
|
|
|
|
|
|
payload = marshalled ? req : @marshal.call(req) |
|
|
|
payload = marshalled ? req : @marshal.call(req) |
|
|
|
@call.run_batch(SEND_MESSAGE => payload) |
|
|
|
@call.run_batch(SEND_MESSAGE => payload) |
|
|
|
end |
|
|
|
end |
|
|
@ -225,11 +224,8 @@ module GRPC |
|
|
|
@call.metadata = batch_result.metadata |
|
|
|
@call.metadata = batch_result.metadata |
|
|
|
@metadata_received = true |
|
|
|
@metadata_received = true |
|
|
|
end |
|
|
|
end |
|
|
|
GRPC.logger.debug("received req: #{batch_result}") |
|
|
|
|
|
|
|
unless batch_result.nil? || batch_result.message.nil? |
|
|
|
unless batch_result.nil? || batch_result.message.nil? |
|
|
|
GRPC.logger.debug("received req.to_s: #{batch_result.message}") |
|
|
|
|
|
|
|
res = @unmarshal.call(batch_result.message) |
|
|
|
res = @unmarshal.call(batch_result.message) |
|
|
|
GRPC.logger.debug("received_req (unmarshalled): #{res.inspect}") |
|
|
|
|
|
|
|
return res |
|
|
|
return res |
|
|
|
end |
|
|
|
end |
|
|
|
GRPC.logger.debug('found nil; the final response has been sent') |
|
|
|
GRPC.logger.debug('found nil; the final response has been sent') |
|
|
|