|
|
|
@ -304,7 +304,7 @@ describe 'ClientStub' do # rubocop:disable Metrics/BlockLength |
|
|
|
|
|
|
|
|
|
describe 'via a call operation' do |
|
|
|
|
after(:each) do |
|
|
|
|
# make sure op.wait doesn't hang, even if there's a bad status |
|
|
|
|
# make sure op.wait doesn't freeze, even if there's a bad status |
|
|
|
|
@op.wait |
|
|
|
|
end |
|
|
|
|
def get_response(stub, run_start_call_first: false, credentials: nil) |
|
|
|
@ -406,7 +406,7 @@ describe 'ClientStub' do # rubocop:disable Metrics/BlockLength |
|
|
|
|
|
|
|
|
|
describe 'via a call operation' do |
|
|
|
|
after(:each) do |
|
|
|
|
# make sure op.wait doesn't hang, even if there's a bad status |
|
|
|
|
# make sure op.wait doesn't freeze, even if there's a bad status |
|
|
|
|
@op.wait |
|
|
|
|
end |
|
|
|
|
def get_response(stub, run_start_call_first: false) |
|
|
|
@ -547,7 +547,7 @@ describe 'ClientStub' do # rubocop:disable Metrics/BlockLength |
|
|
|
|
|
|
|
|
|
describe 'via a call operation' do |
|
|
|
|
after(:each) do |
|
|
|
|
@op.wait # make sure wait doesn't hang |
|
|
|
|
@op.wait # make sure wait doesn't freeze |
|
|
|
|
end |
|
|
|
|
def get_responses(stub, run_start_call_first: false, unmarshal: noop) |
|
|
|
|
@op = stub.server_streamer(@method, @sent_msg, noop, unmarshal, |
|
|
|
@ -865,7 +865,7 @@ describe 'ClientStub' do # rubocop:disable Metrics/BlockLength |
|
|
|
|
|
|
|
|
|
describe 'via a call operation' do |
|
|
|
|
after(:each) do |
|
|
|
|
@op.wait # make sure wait doesn't hang |
|
|
|
|
@op.wait # make sure wait doesn't freeze |
|
|
|
|
end |
|
|
|
|
def get_responses(stub, run_start_call_first: false, deadline: nil, |
|
|
|
|
marshal_proc: noop) |
|
|
|
|