actions/cargo-binstall
1
0
Fork 0
mirror of https://github.com/cargo-bins/cargo-binstall.git synced 2025-06-16 07:36:38 +00:00
Code Issues Projects Releases Packages Wiki Activity

Fix UIThread stopping runtime from shutdown

Browse source 
Signed-off-by: Jiahao XU <Jiahao_XU@outlook.com>
This commit is contained in:
Jiahao XU 2022-06-19 02:07:43 +10:00
parent d4eb56d017
commit 5b0a97f380
No known key found for this signature in database
GPG key ID: 591C0B03040416D6
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/helpers/ui_thread.rs
View file

@ -1,10 +1,10 @@
use std::io::{self, BufRead, Write}; use std::io::{self, BufRead, Write};
use std::thread;
use bytes::Bytes; use bytes::Bytes;
use log::LevelFilter; use log::LevelFilter;
use std::sync::mpsc as mpsc_sync; use std::sync::mpsc as mpsc_sync;
use tokio::sync::mpsc; use tokio::sync::mpsc;
use tokio::task::spawn_blocking;
use super::ui_thread_logger::UIThreadLogger; use super::ui_thread_logger::UIThreadLogger;
use crate::BinstallError; use crate::BinstallError;
@ -36,7 +36,7 @@ impl UIThreadInner {
let (request_tx, request_rx) = mpsc_sync::sync_channel(50); let (request_tx, request_rx) = mpsc_sync::sync_channel(50);
let (confirm_tx, confirm_rx) = mpsc::channel(10); let (confirm_tx, confirm_rx) = mpsc::channel(10);
spawn_blocking(move || { thread::spawn(move || {
// This task should be the only one able to // This task should be the only one able to
// access stdin // access stdin
let mut stdin = io::stdin().lock(); let mut stdin = io::stdin().lock();