| /third_party/grpc/src/ruby/lib/grpc/generic/ |
| D | rpc_server.rb | 418 def available?(an_rpc) argument
419 return an_rpc if @pool.ready_for_work?
425 c = ActiveCall.new(an_rpc.call, noop, noop, an_rpc.deadline,
433 def implemented?(an_rpc) argument
434 mth = an_rpc.method.to_sym
435 return an_rpc if rpc_descs.key?(mth)
436 GRPC.logger.warn("UNIMPLEMENTED: #{an_rpc}")
441 c = ActiveCall.new(an_rpc.call, noop, noop, an_rpc.deadline,
452 an_rpc = @server.request_call
453 break if (!an_rpc.nil?) && an_rpc.call.nil?
[all …]
|
| /third_party/grpc/src/ruby/spec/generic/ |
| D | rpc_server_spec.rb | 53 def an_rpc(_req, _call) method in FailingService
71 def an_rpc(req, call) method in SlowService
97 def an_rpc(req, _call) method in SynchronizedCancellationService
118 def an_rpc(req, call) method in CheckCallAfterFinishedService
374 n.times { expect(stub.an_rpc(req)).to be_a(EchoMsg) }
386 expect(stub.an_rpc(req, metadata: { k1: 'v1', k2: 'v2' }))
403 resp = stub.an_rpc(req,
448 op = stub.an_rpc(req, return_op: true)
484 q << stub.an_rpc(req)
513 stub.an_rpc(req)
[all …]
|
| D | server_interceptors_spec.rb | 41 expect(stub.an_rpc(request)).to be_a(EchoMsg)
55 op = stub.an_rpc(request, client_call_opts)
203 expect(stub.an_rpc(request)).to be_a(EchoMsg)
214 expect(stub.an_rpc(request)).to be_a(EchoMsg)
|
| D | client_interceptors_spec.rb | 36 expect(stub.an_rpc(request)).to be_a(EchoMsg)
49 expect(stub.an_rpc(request)).to be_a(EchoMsg)
|
| /third_party/grpc/src/ruby/spec/ |
| D | google_rpc_status_utils_spec.rb | 127 def an_rpc(_, _) method in GoogleRpcStatusTestService
186 stub.an_rpc(EchoMsg.new)
198 op = stub.an_rpc(EchoMsg.new, return_op: true)
222 def an_rpc(_, _) method in NoStatusDetailsBinTestService
259 stub.an_rpc(EchoMsg.new)
271 op = stub.an_rpc(EchoMsg.new, return_op: true)
|
| D | user_agent_spec.rb | 22 def an_rpc(_req, call) method in UserAgentEchoService
53 response = stub.an_rpc(EchoMsg.new)
66 response = stub.an_rpc(EchoMsg.new)
|
| D | channel_connection_spec.rb | 42 expect(stub.an_rpc(req)).to be_a(EchoMsg)
47 expect(stub.an_rpc(req)).to be_a(EchoMsg)
|
| D | client_auth_spec.rb | 55 def an_rpc(req, call) method in SslTestService
110 @stub.an_rpc(EchoMsg.new)
|
| /third_party/grpc/src/ruby/bin/ |
| D | noproto_client.rb | 89 resp = stub.an_rpc(NoProtoMsg.new)
|
| D | noproto_server.rb | 50 def an_rpc(req, _call) method in NoProto
|
| /third_party/grpc/src/ruby/spec/support/ |
| D | services.rb | 50 def an_rpc(req, call) method in EchoService
|