summaryrefslogtreecommitdiff
path: root/runtime/ops/web_worker.rs
diff options
context:
space:
mode:
authorAaron O'Mullan <aaron.omullan@gmail.com>2021-05-06 19:32:03 +0200
committerGitHub <noreply@github.com>2021-05-06 19:32:03 +0200
commit1e8e44f4c31688ac55100f96bdab27723eb6e575 (patch)
tree820c3b61ded766ecb912eefddaae4894e399555c /runtime/ops/web_worker.rs
parentf208e6a26f3c21c25dbfcfe29491a6f5660c999d (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.rs5
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();