| /external/grpc-grpc/src/ruby/spec/generic/ |
| rpc_desc_spec.rb | 27 @request_response = RpcDesc.new('rr', Object.new, Object.new, 'encode',
74 let(:this_desc) { @request_response }
139 let(:this_desc) { @request_response }
213 it 'raises when a request_response does not have 2 args' do
216 @request_response.assert_arity_matches(method(mth))
222 it 'passes when a request_response has 2 args' do
224 @request_response.assert_arity_matches(method(:fake_svstream))
285 describe '#request_response?' do
287 expect(@request_response.request_response?).to be(true
[all...] |
| server_interceptors_spec.rb | 36 expect(interceptor).to receive(:request_response)
46 expect(interceptor).to receive(:request_response)
52 receive(:request_response).with(request, metadata: client_metadata)
194 expect(interceptor).to receive(:request_response)
196 expect(interceptor2).to receive(:request_response)
198 expect(interceptor3).to receive(:request_response)
|
| client_interceptors_spec.rb | 29 expect(interceptor).to receive(:request_response)
34 expect_any_instance_of(GRPC::ActiveCall).to receive(:request_response)
41 expect(interceptor).to receive(:request_response)
46 expect_any_instance_of(GRPC::ActiveCall).to receive(:request_response)
|
| rpc_server_spec.rb | 320 stub.request_response('/unknown', req, marshal, unmarshal)
335 stub.request_response('/an_rpc', req, marshal, unmarshal)
|
| client_stub_spec.rb | 166 describe '#request_response', request_response: true do
297 stub.request_response(@method, @sent_msg, noop, noop,
311 @op = stub.request_response(@method, @sent_msg, noop, noop,
[all...] |
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| rpc_desc.rb | 55 :request_response,
121 if request_response?
164 elsif request_response? || server_streamer?
175 def request_response?
|
| interceptors.rb | 44 def request_response(request: nil, call: nil, method: nil, metadata: nil) method in class:GRPC.ClientInterceptor
105 def request_response(request: nil, call: nil, method: nil) method in class:GRPC.ServerInterceptor
|
| client_stub.rb | 111 # request_response sends a request to a GRPC server, and returns the
148 def request_response(method, req, marshal, unmarshal, method in class:GRPC.ClientStub
167 # new method for this instance that invokes #request_response.
171 interception_context.intercept!(:request_response, intercept_args) do
172 c.request_response(req, metadata: metadata)
177 interception_context.intercept!(:request_response, intercept_args) do
178 c.request_response(req, metadata: metadata)
|
| service.rb | 167 if desc.request_response?
170 request_response(route, req, marshal, unmarshal, metadata)
|
| active_call.rb | 343 # request_response sends a request to a GRPC server, and returns the
350 def request_response(req, metadata: {}) method in class:GRPC.ActiveCall
|
| /external/grpc-grpc/src/ruby/spec/support/ |
| services.rb | 77 def request_response(request:, call:, method:) method in class:TestServerInterceptor
116 def request_response(request:, call:, method:, metadata: {}) method in class:TestClientInterceptor
|
| /external/python/apitools/apitools/base/py/testing/ |
| mock.py | 229 request_response = self.__mocked_client._request_responses.pop(0)
235 response = request_response.ValidateAndRespond(self.__key, request)
|
