| 412 | descriptor_(std::move(descriptor)) {} |
| 413 | |
| 414 | ~ClientStreamWriter() { |
| 415 | if (closed_) return; |
| 416 | // Implicitly Close() on destruction, though it's best if the |
| 417 | // application closes explicitly |
| 418 | ARROW_WARN_NOT_OK(Close(), "Close() failed"); |
| 419 | } |
| 420 | |
| 421 | Status Begin(const std::shared_ptr<Schema>& schema, |
| 422 | const ipc::IpcWriteOptions& options) override { |