| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | rpc_server.rb | 358 def available?(an_rpc) argument
359 return an_rpc if @pool.ready_for_work?
365 c = ActiveCall.new(an_rpc.call, noop, noop, an_rpc.deadline,
373 def implemented?(an_rpc) argument
374 mth = an_rpc.method.to_sym
375 return an_rpc if rpc_descs.key?(mth)
376 GRPC.logger.warn("UNIMPLEMENTED: #{an_rpc}")
381 c = ActiveCall.new(an_rpc.call, noop, noop, an_rpc.deadline,
392 an_rpc = @server.request_call
393 break if (!an_rpc.nil?) && an_rpc.call.nil?
[all …]
|
| /external/grpc-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
352 n.times { expect(stub.an_rpc(req)).to be_a(EchoMsg) }
364 expect(stub.an_rpc(req, metadata: { k1: 'v1', k2: 'v2' }))
381 resp = stub.an_rpc(req,
426 op = stub.an_rpc(req, return_op: true)
462 q << stub.an_rpc(req)
491 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)
|
| /external/grpc-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 | 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)
|
| /external/grpc-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
|
| /external/grpc-grpc/src/ruby/spec/support/ |
| D | services.rb | 43 def an_rpc(req, call) method in EchoService
|