diff options
author | Divy Srivastava <dj.srivastava23@gmail.com> | 2022-03-14 23:14:15 +0530 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-03-14 18:44:15 +0100 |
commit | b4e42953e1d243f2eda20e5be6b845d60b7bf688 (patch) | |
tree | 10b3bfff165f9c04f9174c7c399d44b9b724c3b3 /runtime/ops/web_worker.rs | |
parent | 4e3ed37037a2aa1edeac260dc3463a81d9cf9b88 (diff) |
feat(core): codegen ops (#13861)
Co-authored-by: Aaron O'Mullan <aaron.omullan@gmail.com>
Diffstat (limited to 'runtime/ops/web_worker.rs')
-rw-r--r-- | runtime/ops/web_worker.rs | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/runtime/ops/web_worker.rs b/runtime/ops/web_worker.rs index e32f2371d..3c64cf1f6 100644 --- a/runtime/ops/web_worker.rs +++ b/runtime/ops/web_worker.rs @@ -5,8 +5,8 @@ mod sync_fetch; use crate::web_worker::WebWorkerInternalHandle; use crate::web_worker::WebWorkerType; use deno_core::error::AnyError; -use deno_core::op_async; -use deno_core::op_sync; +use deno_core::op; + use deno_core::CancelFuture; use deno_core::Extension; use deno_core::OpState; @@ -19,16 +19,17 @@ use self::sync_fetch::op_worker_sync_fetch; pub fn init() -> Extension { Extension::builder() .ops(vec![ - ("op_worker_post_message", op_sync(op_worker_post_message)), - ("op_worker_recv_message", op_async(op_worker_recv_message)), + op_worker_post_message::decl(), + op_worker_recv_message::decl(), // Notify host that guest worker closes. - ("op_worker_close", op_sync(op_worker_close)), - ("op_worker_get_type", op_sync(op_worker_get_type)), - ("op_worker_sync_fetch", op_sync(op_worker_sync_fetch)), + op_worker_close::decl(), + op_worker_get_type::decl(), + op_worker_sync_fetch::decl(), ]) .build() } +#[op] fn op_worker_post_message( state: &mut OpState, data: JsMessageData, @@ -39,6 +40,7 @@ fn op_worker_post_message( Ok(()) } +#[op] async fn op_worker_recv_message( state: Rc<RefCell<OpState>>, _: (), @@ -55,6 +57,7 @@ async fn op_worker_recv_message( .await? } +#[op] fn op_worker_close(state: &mut OpState, _: (), _: ()) -> Result<(), AnyError> { // Notify parent that we're finished let mut handle = state.borrow_mut::<WebWorkerInternalHandle>().clone(); @@ -63,6 +66,7 @@ fn op_worker_close(state: &mut OpState, _: (), _: ()) -> Result<(), AnyError> { Ok(()) } +#[op] fn op_worker_get_type( state: &mut OpState, _: (), |