diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2023-09-14 23:05:18 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-09-14 23:05:18 +0200 |
commit | 5e7435fb8010a6d90f1b88d68ee8c431abf846e1 (patch) | |
tree | 6d4dda4dc6d23f10dfd9f3ec4683a66f88828c27 /runtime/ops/web_worker.rs | |
parent | dc505e905ec256f034a963f12752dcc4187cb7b9 (diff) |
refactor: rewrite more ops to op2 macro (#20478)
Diffstat (limited to 'runtime/ops/web_worker.rs')
-rw-r--r-- | runtime/ops/web_worker.rs | 10 |
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 |