summaryrefslogtreecommitdiff
path: root/runtime/ops/web_worker.rs
diff options
context:
space:
mode:
authorDivy Srivastava <dj.srivastava23@gmail.com>2022-03-14 23:14:15 +0530
committerGitHub <noreply@github.com>2022-03-14 18:44:15 +0100
commitb4e42953e1d243f2eda20e5be6b845d60b7bf688 (patch)
tree10b3bfff165f9c04f9174c7c399d44b9b724c3b3 /runtime/ops/web_worker.rs
parent4e3ed37037a2aa1edeac260dc3463a81d9cf9b88 (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.rs18
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,
_: (),