Skip to content

Commit

Permalink
refactor: tokio::spawn
Browse files Browse the repository at this point in the history
replace async move { fn(x).await} with just tokio::spawn(fn(x))
  • Loading branch information
mrjackwills committed May 30, 2022
1 parent 1674db8 commit 1fd230f
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -32,21 +32,21 @@ async fn main() {
let docker_gui_state = Arc::clone(&gui_state);

let (docker_sx, docker_rx) = tokio::sync::mpsc::channel(16);

// Create docker daemon handler, and only spawn up the docker data handler if ping returns non-error
let docker = Arc::new(Docker::connect_with_socket_defaults().unwrap());
match docker.ping().await {
Ok(_) => {
let docker = Arc::clone(&docker);
tokio::spawn(async move {
tokio::spawn(
DockerData::init(
docker_args,
docker_app_data,
docker,
docker_gui_state,
docker_rx,
)
.await;
});
);
}
Err(_) => app_data.lock().set_error(AppError::DockerConnect),
}
Expand All @@ -55,23 +55,21 @@ async fn main() {

let (input_sx, input_rx) = tokio::sync::mpsc::channel(16);

// let input_docker = Arc::clone(&docker);
let is_running = Arc::new(AtomicBool::new(true));
let input_is_running = Arc::clone(&is_running);
let input_gui_state = Arc::clone(&gui_state);
let input_docker_sender = docker_sx.clone();

// Spawn input handling into own tokio thread
tokio::spawn(async {
tokio::spawn(
input_handler::InputHandler::init(
input_app_data,
input_rx,
input_docker_sender,
input_gui_state,
input_is_running,
)
.await;
});
);

// Debug mode for testing, mostly pointless, doesn't take terminal nor draw gui
if !args.gui {
Expand Down

0 comments on commit 1fd230f

Please sign in to comment.