|
|
void | pw::rpc::integration_test::SetEgressChannelManipulator (ChannelManipulator *new_channel_manipulator) |
| |
|
void | pw::rpc::integration_test::SetIngressChannelManipulator (ChannelManipulator *new_channel_manipulator) |
| |
|
Client & | pw::rpc::integration_test::client () |
| |
|
int | pw::rpc::integration_test::SetClientSockOpt (int level, int optname, const void *optval, unsigned int optlen) |
| |
|
Status | pw::rpc::integration_test::InitializeClient (int argc, char *argv[], const char *usage_args="PORT") |
| |
|
Status | pw::rpc::integration_test::InitializeClient (int port) |
| |
|
void | pw::rpc::integration_test::TerminateClient () |
| |
|
template<unsigned kTimeoutSeconds = 10, typename Function > |
| void | pw::rpc::test::WaitForPackets (internal::test::FakeChannelOutput &output, int count, Function &&run_before) |
| |
|
template<auto kMethod, typename Context > |
| Status | pw::rpc::test::SendResponseIfCalled (Context &client_context, const MethodResponseType< kMethod > &response, Status status=OkStatus(), chrono::SystemClock::duration timeout=chrono::SystemClock::for_at_least(std::chrono::milliseconds(100))) |
| |
|
template<auto kMethod, typename Context > |
| Status | pw::rpc::test::SendResponseIfCalled (Context &client_context, Status status=OkStatus(), chrono::SystemClock::duration timeout=chrono::SystemClock::for_at_least(std::chrono::milliseconds(100))) |
| |
1.9.6 