File tree Expand file tree Collapse file tree
lib/protobuf/rpc/connectors Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -139,12 +139,7 @@ def ping_port_enabled?
139139
140140 def request_bytes
141141 validate_request_type!
142- fields = { :service_name => @options [ :service ] . name ,
143- :method_name => @options [ :method ] . to_s ,
144- :request_proto => @options [ :request ] ,
145- :caller => request_caller }
146-
147- return ::Protobuf ::Socketrpc ::Request . encode ( fields )
142+ return ::Protobuf ::Socketrpc ::Request . encode ( request_fields )
148143 rescue => e
149144 failure ( :INVALID_REQUEST_PROTO , "Could not set request proto: #{ e . message } " )
150145 end
@@ -153,6 +148,13 @@ def request_caller
153148 @options [ :client_host ] || ::Protobuf . client_host
154149 end
155150
151+ def request_fields
152+ { :service_name => @options [ :service ] . name ,
153+ :method_name => @options [ :method ] . to_s ,
154+ :request_proto => @options [ :request ] ,
155+ :caller => request_caller }
156+ end
157+
156158 def send_request
157159 fail 'If you inherit a Connector from Base you must implement send_request'
158160 end
You can’t perform that action at this time.
0 commit comments