diff options
Diffstat (limited to 'runtime/ops/http.rs')
| -rw-r--r-- | runtime/ops/http.rs | 23 |
1 files changed, 14 insertions, 9 deletions
diff --git a/runtime/ops/http.rs b/runtime/ops/http.rs index 4d9787cde..1ab8cb998 100644 --- a/runtime/ops/http.rs +++ b/runtime/ops/http.rs @@ -10,10 +10,13 @@ use deno_core::futures::future::poll_fn; use deno_core::futures::FutureExt; use deno_core::futures::Stream; use deno_core::futures::StreamExt; +use deno_core::op_async; +use deno_core::op_sync; use deno_core::AsyncRefCell; use deno_core::CancelFuture; use deno_core::CancelHandle; use deno_core::CancelTryFuture; +use deno_core::Extension; use deno_core::OpState; use deno_core::RcRef; use deno_core::Resource; @@ -43,15 +46,17 @@ use tokio::sync::oneshot; use tokio_rustls::server::TlsStream; use tokio_util::io::StreamReader; -pub fn init(rt: &mut deno_core::JsRuntime) { - super::reg_sync(rt, "op_http_start", op_http_start); - - super::reg_async(rt, "op_http_request_next", op_http_request_next); - super::reg_async(rt, "op_http_request_read", op_http_request_read); - - super::reg_async(rt, "op_http_response", op_http_response); - super::reg_async(rt, "op_http_response_write", op_http_response_write); - super::reg_async(rt, "op_http_response_close", op_http_response_close); +pub fn init() -> Extension { + Extension::builder() + .ops(vec![ + ("op_http_start", op_sync(op_http_start)), + ("op_http_request_next", op_async(op_http_request_next)), + ("op_http_request_read", op_async(op_http_request_read)), + ("op_http_response", op_async(op_http_response)), + ("op_http_response_write", op_async(op_http_response_write)), + ("op_http_response_close", op_async(op_http_response_close)), + ]) + .build() } struct ServiceInner { |