diff options
author | Bert Belder <bertbelder@gmail.com> | 2020-09-14 18:48:57 +0200 |
---|---|---|
committer | Bert Belder <bertbelder@gmail.com> | 2020-09-15 01:50:52 +0200 |
commit | f5b40c918c7d602827622d167728a3e7bae87d9d (patch) | |
tree | fb51722e043f4d6bce64a2c7e897cce4ead06c82 /cli/ops/worker_host.rs | |
parent | 3da20d19a14ab6838897d281f1b11e49d68bd1a7 (diff) |
refactor: use the 'anyhow' crate instead of 'ErrBox' (#7476)
Diffstat (limited to 'cli/ops/worker_host.rs')
-rw-r--r-- | cli/ops/worker_host.rs | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/cli/ops/worker_host.rs b/cli/ops/worker_host.rs index 6a100b198..392e43dc6 100644 --- a/cli/ops/worker_host.rs +++ b/cli/ops/worker_host.rs @@ -8,8 +8,8 @@ use crate::tokio_util::create_basic_runtime; use crate::web_worker::WebWorker; use crate::web_worker::WebWorkerHandle; use crate::worker::WorkerEvent; +use deno_core::error::AnyError; use deno_core::BufVec; -use deno_core::ErrBox; use deno_core::ModuleSpecifier; use deno_core::OpState; use deno_core::ZeroCopyBuf; @@ -40,7 +40,7 @@ fn create_web_worker( permissions: Permissions, specifier: ModuleSpecifier, has_deno_namespace: bool, -) -> Result<WebWorker, ErrBox> { +) -> Result<WebWorker, AnyError> { let cli_state = crate::state::State::new_for_worker( global_state, Some(permissions), @@ -84,10 +84,10 @@ fn run_worker_thread( specifier: ModuleSpecifier, has_deno_namespace: bool, maybe_source_code: Option<String>, -) -> Result<(JoinHandle<()>, WebWorkerHandle), ErrBox> { +) -> Result<(JoinHandle<()>, WebWorkerHandle), AnyError> { let global_state = global_state.clone(); let (handle_sender, handle_receiver) = - std::sync::mpsc::sync_channel::<Result<WebWorkerHandle, ErrBox>>(1); + std::sync::mpsc::sync_channel::<Result<WebWorkerHandle, AnyError>>(1); let builder = std::thread::Builder::new().name(format!("deno-worker-{}", worker_id)); @@ -177,7 +177,7 @@ fn op_create_worker( state: &mut OpState, args: Value, _data: &mut [ZeroCopyBuf], -) -> Result<Value, ErrBox> { +) -> Result<Value, AnyError> { let cli_state = super::cli_state(state); let args: CreateWorkerArgs = serde_json::from_value(args)?; @@ -229,7 +229,7 @@ fn op_host_terminate_worker( state: &mut OpState, args: Value, _data: &mut [ZeroCopyBuf], -) -> Result<Value, ErrBox> { +) -> Result<Value, AnyError> { let args: WorkerArgs = serde_json::from_value(args)?; let id = args.id as u32; let cli_state = super::cli_state(state); @@ -298,7 +298,7 @@ async fn op_host_get_message( state: Rc<RefCell<OpState>>, args: Value, _zero_copy: BufVec, -) -> Result<Value, ErrBox> { +) -> Result<Value, AnyError> { let args: WorkerArgs = serde_json::from_value(args)?; let id = args.id as u32; let cli_state = super::cli_state2(&state); @@ -347,7 +347,7 @@ fn op_host_post_message( state: &mut OpState, args: Value, data: &mut [ZeroCopyBuf], -) -> Result<Value, ErrBox> { +) -> Result<Value, AnyError> { assert_eq!(data.len(), 1, "Invalid number of arguments"); let args: WorkerArgs = serde_json::from_value(args)?; let id = args.id as u32; |