1 files changed, 5 insertions, 6 deletions
diff --git a/runtime/ops/web_worker.rs b/runtime/ops/web_worker.rs
index e28bf2192..d0c3eea66 100644
--- a/runtime/ops/web_worker.rs
+++ b/runtime/ops/web_worker.rs
@@ -4,15 +4,16 @@ mod sync_fetch;
 
 use crate::web_worker::WebWorkerInternalHandle;
 use crate::web_worker::WebWorkerType;
-use deno_core::error::AnyError;
 use deno_core::op2;
 use deno_core::CancelFuture;
 use deno_core::OpState;
 use deno_web::JsMessageData;
+use deno_web::MessagePortError;
 use std::cell::RefCell;
 use std::rc::Rc;
 
 use self::sync_fetch::op_worker_sync_fetch;
+pub use sync_fetch::SyncFetchError;
 
 deno_core::extension!(
   deno_web_worker,
@@ -30,17 +31,16 @@ deno_core::extension!(
 fn op_worker_post_message(
   state: &mut OpState,
   #[serde] data: JsMessageData,
-) -> Result<(), AnyError> {
+) -> Result<(), MessagePortError> {
   let handle = state.borrow::<WebWorkerInternalHandle>().clone();
-  handle.port.send(state, data)?;
-  Ok(())
+  handle.port.send(state, data)
 }
 
 #[op2(async(lazy), fast)]
 #[serde]
 async fn op_worker_recv_message(
   state: Rc<RefCell<OpState>>,
-) -> Result<Option<JsMessageData>, AnyError> {
+) -> Result<Option<JsMessageData>, MessagePortError> {
   let handle = {
     let state = state.borrow();
     state.borrow::<WebWorkerInternalHandle>().clone()
@@ -50,7 +50,6 @@ async fn op_worker_recv_message(
     .recv(state.clone())
     .or_cancel(handle.cancel)
     .await?
-    .map_err(|e| e.into())
 }
 
 #[op2(fast)]