diff options
author | Aaron O'Mullan <aaron.omullan@gmail.com> | 2021-04-02 15:47:57 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-04-02 09:47:57 -0400 |
commit | 058579da562989ed15c86598053644bbc86c6747 (patch) | |
tree | 7f0f2bf30684dcbb350b93d987771f17a4abd250 /runtime/ops/net_unix.rs | |
parent | adf57610904cb4f4ef25fb077f6e39c9017a4ea9 (diff) |
refactor(ops): remove variadic buffers (#9944)
Diffstat (limited to 'runtime/ops/net_unix.rs')
-rw-r--r-- | runtime/ops/net_unix.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/runtime/ops/net_unix.rs b/runtime/ops/net_unix.rs index 6d9afb70f..0cc001ab4 100644 --- a/runtime/ops/net_unix.rs +++ b/runtime/ops/net_unix.rs @@ -5,16 +5,17 @@ use crate::ops::net::AcceptArgs; use crate::ops::net::ReceiveArgs; use deno_core::error::bad_resource; use deno_core::error::custom_error; +use deno_core::error::null_opbuf; use deno_core::error::AnyError; use deno_core::serde_json::json; use deno_core::serde_json::Value; use deno_core::AsyncRefCell; -use deno_core::BufVec; use deno_core::CancelHandle; use deno_core::CancelTryFuture; use deno_core::OpState; use deno_core::RcRef; use deno_core::Resource; +use deno_core::ZeroCopyBuf; use serde::Deserialize; use std::borrow::Cow; use std::cell::RefCell; @@ -63,7 +64,7 @@ pub struct UnixListenArgs { pub(crate) async fn accept_unix( state: Rc<RefCell<OpState>>, args: AcceptArgs, - _bufs: BufVec, + _bufs: Option<ZeroCopyBuf>, ) -> Result<Value, AnyError> { let rid = args.rid; @@ -100,12 +101,11 @@ pub(crate) async fn accept_unix( pub(crate) async fn receive_unix_packet( state: Rc<RefCell<OpState>>, args: ReceiveArgs, - bufs: BufVec, + buf: Option<ZeroCopyBuf>, ) -> Result<Value, AnyError> { - assert_eq!(bufs.len(), 1, "Invalid number of arguments"); + let mut buf = buf.ok_or_else(null_opbuf)?; let rid = args.rid; - let mut buf = bufs.into_iter().next().unwrap(); let resource = state .borrow() |