summaryrefslogtreecommitdiff
path: root/runtime/ops/web_worker.rs
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2023-09-14 23:05:18 +0200
committerGitHub <noreply@github.com>2023-09-14 23:05:18 +0200
commit5e7435fb8010a6d90f1b88d68ee8c431abf846e1 (patch)
tree6d4dda4dc6d23f10dfd9f3ec4683a66f88828c27 /runtime/ops/web_worker.rs
parentdc505e905ec256f034a963f12752dcc4187cb7b9 (diff)
refactor: rewrite more ops to op2 macro (#20478)
Diffstat (limited to 'runtime/ops/web_worker.rs')
-rw-r--r--runtime/ops/web_worker.rs10
1 files changed, 6 insertions, 4 deletions
diff --git a/runtime/ops/web_worker.rs b/runtime/ops/web_worker.rs
index e62642fdd..bdf03d98f 100644
--- a/runtime/ops/web_worker.rs
+++ b/runtime/ops/web_worker.rs
@@ -6,6 +6,7 @@ use crate::web_worker::WebWorkerInternalHandle;
use crate::web_worker::WebWorkerType;
use deno_core::error::AnyError;
use deno_core::op;
+use deno_core::op2;
use deno_core::CancelFuture;
use deno_core::OpState;
@@ -27,10 +28,10 @@ deno_core::extension!(
],
);
-#[op]
+#[op2]
fn op_worker_post_message(
state: &mut OpState,
- data: JsMessageData,
+ #[serde] data: JsMessageData,
) -> Result<(), AnyError> {
let handle = state.borrow::<WebWorkerInternalHandle>().clone();
handle.port.send(state, data)?;
@@ -52,7 +53,7 @@ async fn op_worker_recv_message(
.await?
}
-#[op]
+#[op2(fast)]
fn op_worker_close(state: &mut OpState) {
// Notify parent that we're finished
let mut handle = state.borrow_mut::<WebWorkerInternalHandle>().clone();
@@ -60,7 +61,8 @@ fn op_worker_close(state: &mut OpState) {
handle.terminate();
}
-#[op]
+#[op2]
+#[serde]
fn op_worker_get_type(state: &mut OpState) -> WebWorkerType {
let handle = state.borrow::<WebWorkerInternalHandle>().clone();
handle.worker_type