53     service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(),  in BM_PumpStreamClientToServer()
54                               fixture->cq(), tag(0));  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()
122     service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(),  in BM_PumpStreamServerToClient()
123                               fixture->cq(), tag(0));  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()