diff options
Diffstat (limited to 'ext/web')
-rw-r--r-- | ext/web/lib.rs | 6 | ||||
-rw-r--r-- | ext/web/message_port.rs | 12 |
2 files changed, 5 insertions, 13 deletions
diff --git a/ext/web/lib.rs b/ext/web/lib.rs index 9ee1eac7b..87ae46f2f 100644 --- a/ext/web/lib.rs +++ b/ext/web/lib.rs @@ -3,7 +3,6 @@ mod blob; mod message_port; -use deno_core::error::bad_resource_id; use deno_core::error::range_error; use deno_core::error::type_error; use deno_core::error::AnyError; @@ -240,10 +239,7 @@ fn op_encoding_decode( ) -> Result<String, AnyError> { let DecodeOptions { rid, stream } = options; - let resource = state - .resource_table - .get::<TextDecoderResource>(rid) - .ok_or_else(bad_resource_id)?; + let resource = state.resource_table.get::<TextDecoderResource>(rid)?; let mut decoder = resource.decoder.borrow_mut(); let fatal = resource.fatal; diff --git a/ext/web/message_port.rs b/ext/web/message_port.rs index f73d0486a..4af99d501 100644 --- a/ext/web/message_port.rs +++ b/ext/web/message_port.rs @@ -2,7 +2,6 @@ use std::borrow::Cow; use std::cell::RefCell; use std::rc::Rc; -use deno_core::error::bad_resource_id; use deno_core::error::type_error; use deno_core::error::AnyError; use deno_core::ZeroCopyBuf; @@ -141,7 +140,7 @@ fn deserialize_js_transferables( let resource = state .resource_table .take::<MessagePortResource>(id) - .ok_or_else(|| type_error("Invalid message port transfer"))?; + .map_err(|_| type_error("Invalid message port transfer"))?; resource.cancel.cancel(); let resource = Rc::try_unwrap(resource) .map_err(|_| type_error("Message port is not ready for transfer"))?; @@ -192,10 +191,7 @@ pub fn op_message_port_post_message( } } - let resource = state - .resource_table - .get::<MessagePortResource>(rid) - .ok_or_else(bad_resource_id)?; + let resource = state.resource_table.get::<MessagePortResource>(rid)?; resource.port.send(state, data) } @@ -208,8 +204,8 @@ pub async fn op_message_port_recv_message( let resource = { let state = state.borrow(); match state.resource_table.get::<MessagePortResource>(rid) { - Some(resource) => resource, - None => return Ok(None), + Ok(resource) => resource, + Err(_) => return Ok(None), } }; let cancel = RcRef::map(resource.clone(), |r| &r.cancel); |