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