|
|
|
@ -323,7 +323,7 @@ describe GRPC::RpcServer do |
|
|
|
|
end |
|
|
|
|
|
|
|
|
|
describe 'when running' do |
|
|
|
|
it 'should return NOT_FOUND status for requests on unknown methods' do |
|
|
|
|
it 'should return NOT_FOUND status on unknown methods', server: true do |
|
|
|
|
@srv.handle(EchoService) |
|
|
|
|
t = Thread.new { @srv.run } |
|
|
|
|
@srv.wait_till_running |
|
|
|
@ -338,7 +338,7 @@ describe GRPC::RpcServer do |
|
|
|
|
t.join |
|
|
|
|
end |
|
|
|
|
|
|
|
|
|
it 'should obtain responses for multiple sequential requests' do |
|
|
|
|
it 'should handle multiple sequential requests', server: true do |
|
|
|
|
@srv.handle(EchoService) |
|
|
|
|
t = Thread.new { @srv.run } |
|
|
|
|
@srv.wait_till_running |
|
|
|
@ -350,7 +350,7 @@ describe GRPC::RpcServer do |
|
|
|
|
t.join |
|
|
|
|
end |
|
|
|
|
|
|
|
|
|
it 'should obtain responses for multiple parallel requests' do |
|
|
|
|
it 'should handle multiple parallel requests', server: true do |
|
|
|
|
@srv.handle(EchoService) |
|
|
|
|
Thread.new { @srv.run } |
|
|
|
|
@srv.wait_till_running |
|
|
|
@ -368,7 +368,7 @@ describe GRPC::RpcServer do |
|
|
|
|
threads.each(&:join) |
|
|
|
|
end |
|
|
|
|
|
|
|
|
|
it 'should return UNAVAILABLE status if there too many jobs' do |
|
|
|
|
it 'should return UNAVAILABLE on too many jobs', server: true do |
|
|
|
|
opts = { |
|
|
|
|
a_channel_arg: 'an_arg', |
|
|
|
|
server_override: @server, |
|
|
|
|