std::unique_ptr GCSFileManager::getInputStream()

in fbpcf/io/GCSFileManager.h [47:57]


std::unique_ptr<IInputStream> GCSFileManager<ClientCls>::getInputStream(
    const std::string& fileName) {
  const auto& ref = fbpcf::gcp::uriToObjectReference(fileName);

  auto outcome = GCSClient_->ReadObject(ref.bucket, ref.key, gcs::ReadRange());
  if (!outcome.status().ok()) {
    throw GcpException{outcome.status().message()};
  }

  return std::make_unique<GCSInputStream>(std::move(outcome));
}