Skip to content

Commit 996f4f4

Browse files
committed
Creating request fields in new Base#request_fields method.
1 parent e8a2bf6 commit 996f4f4

1 file changed

Lines changed: 8 additions & 6 deletions

File tree

lib/protobuf/rpc/connectors/base.rb

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -137,14 +137,16 @@ def ping_port_enabled?
137137
ENV.key?("PB_RPC_PING_PORT")
138138
end
139139

140+
def request_fields
141+
{ :service_name => @options[:service].name,
142+
:method_name => @options[:method].to_s,
143+
:request_proto => @options[:request],
144+
:caller => request_caller }
145+
end
146+
140147
def request_bytes
141148
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)
149+
return ::Protobuf::Socketrpc::Request.encode(request_fields)
148150
rescue => e
149151
failure(:INVALID_REQUEST_PROTO, "Could not set request proto: #{e.message}")
150152
end

0 commit comments

Comments
 (0)