43   std::unique_ptr<Fixture> fixture(new Fixture(&service));  in BM_PumpStreamClientToServer()
53     service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(),  in BM_PumpStreamClientToServer()
54                               fixture->cq(), tag(0));  in BM_PumpStreamClientToServer()
56         EchoTestService::NewStub(fixture->channel()));  in BM_PumpStreamClientToServer()
58     auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1));  in BM_PumpStreamClientToServer()
63       GPR_ASSERT(fixture->cq()->Next(&t, &ok));  in BM_PumpStreamClientToServer()
74         GPR_ASSERT(fixture->cq()->Next(&t, &ok));  in BM_PumpStreamClientToServer()
87       GPR_ASSERT(fixture->cq()->Next(&t, &ok));  in BM_PumpStreamClientToServer()
97       GPR_ASSERT(fixture->cq()->Next(&t, &ok));  in BM_PumpStreamClientToServer()
104   fixture->Finish(state);  in BM_PumpStreamClientToServer()
105   fixture.reset();  in BM_PumpStreamClientToServer()
112   std::unique_ptr<Fixture> fixture(new Fixture(&service));  in BM_PumpStreamServerToClient()
122     service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(),  in BM_PumpStreamServerToClient()
123                               fixture->cq(), tag(0));  in BM_PumpStreamServerToClient()
125         EchoTestService::NewStub(fixture->channel()));  in BM_PumpStreamServerToClient()
127     auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1));  in BM_PumpStreamServerToClient()
132       GPR_ASSERT(fixture->cq()->Next(&t, &ok));  in BM_PumpStreamServerToClient()
143         GPR_ASSERT(fixture->cq()->Next(&t, &ok));  in BM_PumpStreamServerToClient()
156       GPR_ASSERT(fixture->cq()->Next(&t, &ok));  in BM_PumpStreamServerToClient()
162   fixture->Finish(state);  in BM_PumpStreamServerToClient()
163   fixture.reset();  in BM_PumpStreamServerToClient()