149         stream_(num_threads_),  in SynchronousStreamingClient()
159       stream_[thread_idx]->Finish().IgnoreError();  in ~SynchronousStreamingClient()
165   std::vector<std::unique_ptr<StreamType>> stream_;  member in grpc::testing::SynchronousStreamingClient
178     Status s = stream_[thread_idx]->Finish();  in FinishStream()
200         if (stream_[i]) {  in CleanupAllStreams()
226         [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });  in ~SynchronousStreamingPingPongClient()
234       stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);  in InitThreadFuncImpl()
248     if (stream_[thread_idx]->Write(request_) &&  in ThreadFuncImpl()
249         stream_[thread_idx]->Read(&responses_[thread_idx])) {  in ThreadFuncImpl()
261     stream_[thread_idx]->WritesDone();  in ThreadFuncImpl()
266       stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);  in ThreadFuncImpl()
268       stream_[thread_idx].reset();  in ThreadFuncImpl()
283         [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });  in ~SynchronousStreamingFromClientClient()
293       stream_[thread_idx] = stub->StreamingFromClient(&context_[thread_idx],  in InitThreadFuncImpl()
308     if (stream_[thread_idx]->Write(request_)) {  in ThreadFuncImpl()
314     stream_[thread_idx]->WritesDone();  in ThreadFuncImpl()
319       stream_[thread_idx] = stub->StreamingFromClient(&context_[thread_idx],  in ThreadFuncImpl()
322       stream_[thread_idx].reset();  in ThreadFuncImpl()
343       stream_[thread_idx] =  in InitThreadFuncImpl()
354     if (stream_[thread_idx]->Read(&responses_[thread_idx])) {  in ThreadFuncImpl()
364       stream_[thread_idx] =  in ThreadFuncImpl()
367       stream_[thread_idx].reset();  in ThreadFuncImpl()
382         [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });  in ~SynchronousStreamingBothWaysClient()
390       stream_[thread_idx] = stub->StreamingBothWays(&context_[thread_idx]);  in InitThreadFuncImpl()