summaryrefslogtreecommitdiff
path: root/runtime/ops/web_worker.rs
diff options
context:
space:
mode:
authorAaron O'Mullan <aaron.omullan@gmail.com>2021-04-02 15:47:57 +0200
committerGitHub <noreply@github.com>2021-04-02 09:47:57 -0400
commit058579da562989ed15c86598053644bbc86c6747 (patch)
tree7f0f2bf30684dcbb350b93d987771f17a4abd250 /runtime/ops/web_worker.rs
parentadf57610904cb4f4ef25fb077f6e39c9017a4ea9 (diff)
refactor(ops): remove variadic buffers (#9944)
Diffstat (limited to 'runtime/ops/web_worker.rs')
-rw-r--r--runtime/ops/web_worker.rs7
1 files changed, 4 insertions, 3 deletions
diff --git a/runtime/ops/web_worker.rs b/runtime/ops/web_worker.rs
index 17561882e..7918b97ea 100644
--- a/runtime/ops/web_worker.rs
+++ b/runtime/ops/web_worker.rs
@@ -2,6 +2,7 @@
use crate::web_worker::WebWorkerHandle;
use crate::web_worker::WorkerEvent;
+use deno_core::error::null_opbuf;
use deno_core::futures::channel::mpsc;
use deno_core::serde_json::{json, Value};
@@ -15,9 +16,9 @@ pub fn init(
super::reg_json_sync(
rt,
"op_worker_post_message",
- move |_state, _args: Value, bufs| {
- assert_eq!(bufs.len(), 1, "Invalid number of arguments");
- let msg_buf: Box<[u8]> = (*bufs[0]).into();
+ move |_state, _args: Value, buf| {
+ let buf = buf.ok_or_else(null_opbuf)?;
+ let msg_buf: Box<[u8]> = (*buf).into();
sender_
.clone()
.try_send(WorkerEvent::Message(msg_buf))