| 298 | : stream_(std::move(stream)) {} |
| 299 | |
| 300 | Status ReadMetadata(std::shared_ptr<Buffer>* out) override { |
| 301 | if (!stream_->ReadPutMetadata(out)) { |
| 302 | return stream_->Finish(Status::OK()); |
| 303 | } |
| 304 | return Status::OK(); |
| 305 | } |
| 306 | |
| 307 | private: |
| 308 | std::shared_ptr<internal::ClientDataStream> stream_; |