diff options
author | Leo K <crowlkats@toaxl.com> | 2021-10-05 22:38:27 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-10-05 22:38:27 +0200 |
commit | 77a00ce1fb4ae2523e22b9b84ae09a0200502e38 (patch) | |
tree | 0027a2ff3dbff1e2b0c3afa7ce0f0e54805c7d62 /ext/net/ops.rs | |
parent | d67e85850688117e116bbf7054e80f30fe07afe6 (diff) |
chore: various op cleanup (#12329)
Diffstat (limited to 'ext/net/ops.rs')
-rw-r--r-- | ext/net/ops.rs | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/ext/net/ops.rs b/ext/net/ops.rs index 52e513f71..7019a9b1f 100644 --- a/ext/net/ops.rs +++ b/ext/net/ops.rs @@ -7,7 +7,6 @@ use crate::NetPermissions; use deno_core::error::bad_resource; use deno_core::error::custom_error; use deno_core::error::generic_error; -use deno_core::error::null_opbuf; use deno_core::error::type_error; use deno_core::error::AnyError; use deno_core::op_async; @@ -167,9 +166,8 @@ pub(crate) struct ReceiveArgs { async fn receive_udp( state: Rc<RefCell<OpState>>, args: ReceiveArgs, - zero_copy: Option<ZeroCopyBuf>, + zero_copy: ZeroCopyBuf, ) -> Result<OpPacket, AnyError> { - let zero_copy = zero_copy.ok_or_else(null_opbuf)?; let mut zero_copy = zero_copy.clone(); let rid = args.rid; @@ -197,7 +195,7 @@ async fn receive_udp( async fn op_datagram_receive( state: Rc<RefCell<OpState>>, args: ReceiveArgs, - zero_copy: Option<ZeroCopyBuf>, + zero_copy: ZeroCopyBuf, ) -> Result<OpPacket, AnyError> { match args.transport.as_str() { "udp" => receive_udp(state, args, zero_copy).await, @@ -218,12 +216,11 @@ struct SendArgs { async fn op_datagram_send<NP>( state: Rc<RefCell<OpState>>, args: SendArgs, - zero_copy: Option<ZeroCopyBuf>, + zero_copy: ZeroCopyBuf, ) -> Result<usize, AnyError> where NP: NetPermissions + 'static, { - let zero_copy = zero_copy.ok_or_else(null_opbuf)?; let zero_copy = zero_copy.clone(); match args { |