summaryrefslogtreecommitdiff
path: root/cli/ops/fetch.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/ops/fetch.rs')
-rw-r--r--cli/ops/fetch.rs9
1 files changed, 5 insertions, 4 deletions
diff --git a/cli/ops/fetch.rs b/cli/ops/fetch.rs
index 54ea7ea13..4a7b45430 100644
--- a/cli/ops/fetch.rs
+++ b/cli/ops/fetch.rs
@@ -12,7 +12,7 @@ use http::Method;
use std::convert::From;
pub fn init(i: &mut Isolate, s: &State) {
- i.register_op("op_fetch", s.stateful_json_op(op_fetch));
+ i.register_op("op_fetch", s.stateful_json_op2(op_fetch));
}
#[derive(Deserialize)]
@@ -23,6 +23,7 @@ struct FetchArgs {
}
pub fn op_fetch(
+ isolate: &mut deno_core::Isolate,
state: &State,
args: Value,
data: Option<ZeroCopyBuf>,
@@ -64,8 +65,8 @@ pub fn op_fetch(
request = request.header(name, v);
}
debug!("Before fetch {}", url);
- let state_ = state.clone();
+ let resource_table = isolate.resource_table.clone();
let future = async move {
let res = request.send().await?;
debug!("Fetch response {}", url);
@@ -76,8 +77,8 @@ pub fn op_fetch(
}
let body = HttpBody::from(res);
- let mut state = state_.borrow_mut();
- let rid = state.resource_table.add(
+ let mut resource_table = resource_table.borrow_mut();
+ let rid = resource_table.add(
"httpBody",
Box::new(StreamResourceHolder::new(StreamResource::HttpBody(
Box::new(body),