diff options
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 |