| 245 | : stream_(stream) {} |
| 246 | |
| 247 | Status Read(std::string* token) override { |
| 248 | pb::HandshakeResponse request; |
| 249 | if (stream_->Read(&request)) { |
| 250 | *token = std::move(*request.mutable_payload()); |
| 251 | return Status::OK(); |
| 252 | } |
| 253 | return FromGrpcStatus(stream_->Finish()); |
| 254 | } |
| 255 | |
| 256 | private: |
| 257 | std::shared_ptr<::grpc::ClientReaderWriter<pb::HandshakeRequest, pb::HandshakeResponse>> |