|
|
|
@ -76,7 +76,7 @@ void UnaryCompressionChecks(const InteropClientContextInspector& inspector, |
|
|
|
|
|
|
|
|
|
InteropClient::ServiceStub::ServiceStub( |
|
|
|
|
ChannelCreationFunc channel_creation_func, bool new_stub_every_call) |
|
|
|
|
: channel_creation_func_(channel_creation_func), |
|
|
|
|
: channel_creation_func_(std::move(channel_creation_func)), |
|
|
|
|
channel_(channel_creation_func_()), |
|
|
|
|
new_stub_every_call_(new_stub_every_call) { |
|
|
|
|
// If new_stub_every_call is false, then this is our chance to initialize
|
|
|
|
@ -112,7 +112,7 @@ void InteropClient::ServiceStub::ResetChannel() { |
|
|
|
|
InteropClient::InteropClient(ChannelCreationFunc channel_creation_func, |
|
|
|
|
bool new_stub_every_test_case, |
|
|
|
|
bool do_not_abort_on_transient_failures) |
|
|
|
|
: serviceStub_(channel_creation_func, new_stub_every_test_case), |
|
|
|
|
: serviceStub_(std::move(channel_creation_func), new_stub_every_test_case), |
|
|
|
|
do_not_abort_on_transient_failures_(do_not_abort_on_transient_failures) {} |
|
|
|
|
|
|
|
|
|
bool InteropClient::AssertStatusOk(const Status& s, |
|
|
|
|