Add req_perform_open, which makes resp$body the underlying stream

NAMESPACE

@@ -73,6 +73,7 @@ export(req_oauth_refresh)
 export(req_options)
 export(req_perform)
 export(req_perform_iterative)
+export(req_perform_open)
 export(req_perform_parallel)
 export(req_perform_promise)
 export(req_perform_sequential)

R/req-perform-stream.R

@@ -96,6 +96,39 @@
   resp
 }
 
+
+#' @export
+req_perform_open <- function(req, blocking = TRUE) {
+
+  check_request(req)
+
+  handle <- req_handle(req)
+
+  stream <- curl::curl(req$url, handle = handle)
+  open(stream, "rbf", blocking = blocking)
+
+  res <- curl::handle_data(handle)
+  the$last_request <- req
+
+  # Return early if there's a problem
+  resp <- new_response(
+    method = req_method_get(req),
+    url = res$url,
+    status_code = res$status_code,
+    headers = as_headers(res$headers),
+    body = NULL,
+    request = req
+  )
+  the$last_repsonse <- resp
+  if (error_is_error(req, resp)) {
+    resp$body <- read_con(stream)
+    handle_resp(req, resp)
+  } else {
+    resp$body <- stream
+    resp
+  }
+}
+
 as_round_function <- function(round = c("byte", "line"),
                               error_call = caller_env()) {
   if (is.function(round)) {