150         stream_(num_threads_),  in SynchronousStreamingClient()
160       stream_[thread_idx]->Finish().IgnoreError();  in ~SynchronousStreamingClient()
166   std::vector<std::unique_ptr<StreamType>> stream_;  member in grpc::testing::SynchronousStreamingClient
179     Status s = stream_[thread_idx]->Finish();  in FinishStream()
201         if (stream_[i]) {  in CleanupAllStreams()
227         [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });  in ~SynchronousStreamingPingPongClient()
235       stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);  in InitThreadFuncImpl()
249     if (stream_[thread_idx]->Write(request_) &&  in ThreadFuncImpl()
250         stream_[thread_idx]->Read(&responses_[thread_idx])) {  in ThreadFuncImpl()
262     stream_[thread_idx]->WritesDone();  in ThreadFuncImpl()
267       stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);  in ThreadFuncImpl()
269       stream_[thread_idx].reset();  in ThreadFuncImpl()
284         [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });  in ~SynchronousStreamingFromClientClient()
294       stream_[thread_idx] = stub->StreamingFromClient(&context_[thread_idx],  in InitThreadFuncImpl()
309     if (stream_[thread_idx]->Write(request_)) {  in ThreadFuncImpl()
315     stream_[thread_idx]->WritesDone();  in ThreadFuncImpl()
320       stream_[thread_idx] = stub->StreamingFromClient(&context_[thread_idx],  in ThreadFuncImpl()
323       stream_[thread_idx].reset();  in ThreadFuncImpl()
344       stream_[thread_idx] =  in InitThreadFuncImpl()
355     if (stream_[thread_idx]->Read(&responses_[thread_idx])) {  in ThreadFuncImpl()
365       stream_[thread_idx] =  in ThreadFuncImpl()
368       stream_[thread_idx].reset();  in ThreadFuncImpl()
383         [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });  in ~SynchronousStreamingBothWaysClient()
391       stream_[thread_idx] = stub->StreamingBothWays(&context_[thread_idx]);  in InitThreadFuncImpl()