summaryrefslogtreecommitdiff
path: root/cli/compilers/wasm.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/compilers/wasm.rs')
-rw-r--r--cli/compilers/wasm.rs8
1 files changed, 3 insertions, 5 deletions
diff --git a/cli/compilers/wasm.rs b/cli/compilers/wasm.rs
index d6f0d2f4a..bc056d4f9 100644
--- a/cli/compilers/wasm.rs
+++ b/cli/compilers/wasm.rs
@@ -3,10 +3,9 @@ use super::compiler_worker::CompilerWorker;
use crate::compilers::CompiledModule;
use crate::file_fetcher::SourceFile;
use crate::global_state::GlobalState;
-use crate::ops::worker_host::run_worker_loop;
use crate::startup_data;
use crate::state::*;
-use crate::tokio_util::create_basic_runtime;
+use crate::tokio_util;
use crate::worker::WorkerEvent;
use crate::worker::WorkerHandle;
use deno_core::Buf;
@@ -123,11 +122,10 @@ async fn execute_in_thread(
let builder =
std::thread::Builder::new().name("deno-wasm-compiler".to_string());
let join_handle = builder.spawn(move || {
- let mut worker = WasmCompiler::setup_worker(global_state);
+ let worker = WasmCompiler::setup_worker(global_state);
handle_sender.send(Ok(worker.thread_safe_handle())).unwrap();
drop(handle_sender);
- let mut rt = create_basic_runtime();
- run_worker_loop(&mut rt, &mut worker).expect("Panic in event loop");
+ tokio_util::run_basic(worker).expect("Panic in event loop");
})?;
let mut handle = handle_receiver.recv().unwrap()?;
handle.post_message(req).await?;