diff options
author | Aaron O'Mullan <aaron.omullan@gmail.com> | 2021-05-06 19:32:03 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-05-06 19:32:03 +0200 |
commit | 1e8e44f4c31688ac55100f96bdab27723eb6e575 (patch) | |
tree | 820c3b61ded766ecb912eefddaae4894e399555c /runtime/ops/web_worker.rs | |
parent | f208e6a26f3c21c25dbfcfe29491a6f5660c999d (diff) |
refactor(ops): replace `ZeroCopyBuf` arg by 2nd generic deserializable arg (#10448)
Diffstat (limited to 'runtime/ops/web_worker.rs')
-rw-r--r-- | runtime/ops/web_worker.rs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/runtime/ops/web_worker.rs b/runtime/ops/web_worker.rs index 17b72cb38..1689b2587 100644 --- a/runtime/ops/web_worker.rs +++ b/runtime/ops/web_worker.rs @@ -6,13 +6,14 @@ use deno_core::error::null_opbuf; use deno_core::futures::channel::mpsc; use deno_core::op_sync; use deno_core::Extension; +use deno_core::ZeroCopyBuf; pub fn init() -> Extension { Extension::builder() .ops(vec![ ( "op_worker_post_message", - op_sync(move |state, _args: (), buf| { + op_sync(move |state, _args: (), buf: Option<ZeroCopyBuf>| { let buf = buf.ok_or_else(null_opbuf)?; let msg_buf: Box<[u8]> = (*buf).into(); let mut sender = state.borrow::<mpsc::Sender<WorkerEvent>>().clone(); @@ -25,7 +26,7 @@ pub fn init() -> Extension { // Notify host that guest worker closes. ( "op_worker_close", - op_sync(move |state, _args: (), _bufs| { + op_sync(move |state, _: (), _: ()| { // Notify parent that we're finished let mut sender = state.borrow::<mpsc::Sender<WorkerEvent>>().clone(); sender.close_channel(); |