尝试变异步代码，但是好像不是异步，但是好歹是在tokio里跑了

Author: cht

Cargo.toml

@@ -10,8 +10,10 @@ description = "a v2ray tui"
 [dependencies]
 tui = {version = "0.16.0",  features = ["crossterm"] }
 crossterm = "0.20"
-reqwest = { version = "0.11", default-features = false, features = ["blocking", "json","rustls-tls"] }
+reqwest = { version = "0.11", default-features = false, features = ["json","rustls-tls"] }
 base64 = "0.13.0"
 serde_json = "1.0"
 urlencoding = "2.1.0"
 unicode-width = "0.1"
+tokio = { version = "1", features = ["full"] }
+async-trait = "0.1.51"

src/app.rs

@@ -1,7 +1,8 @@
 use crate::state::{MyBackend, IFEXIT};
 use std::io;
 use tui::Terminal;
-
+use async_trait::async_trait;
+#[async_trait]
 pub trait App {
-    fn run_app_local(&mut self, terminal: &mut Terminal<MyBackend>) -> io::Result<IFEXIT>;
+    async fn run_app_local(&mut self, terminal: &mut Terminal<MyBackend>) -> io::Result<IFEXIT>;
 }

src/informations/appbar.rs

@@ -49,8 +49,10 @@ impl<'a> AppBar<'a> {
         self.data.insert(0, value);
     }
 }
+use async_trait::async_trait;
+#[async_trait]
 impl<'a> App for AppBar<'a> {
-    fn run_app_local(
+    async fn run_app_local(
         &mut self,
         terminal: &mut Terminal<MyBackend>,
     ) -> io::Result<crate::state::IFEXIT> {

src/main.rs

@@ -12,16 +12,16 @@ mod state;
 mod subscribe;
 mod utils;
 //use app::*;
-
-fn main() -> Result<(), Box<dyn Error>> {
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error>> {
     // setup terminal
     enable_raw_mode()?;
     let mut stdout = io::stdout();
     execute!(stdout, EnterAlternateScreen, EnableMouseCapture)?;
     let backend = CrosstermBackend::new(stdout);
     let mut terminal = Terminal::new(backend)?;
 
-    let res = state::run_app(&mut terminal);
+    let res = state::run_app(&mut terminal).await;
 
     // restore terminal
     disable_raw_mode()?;

src/spider.rs

@@ -31,10 +31,10 @@ fn ascii_to_string2(code: Vec<u8>) -> String {
     }
     test
 }
-pub fn get_the_key(paths: Vec<String>) -> Result<Vec<Vec<String>>> {
+pub async fn get_the_key(paths: Vec<String>) -> Result<Vec<Vec<String>>> {
     let mut output: Vec<Vec<String>> = vec![];
     for apath in paths {
-        let temp = reqwest::blocking::get(apath)?.bytes()?.to_vec();
+        let temp = reqwest::get(apath).await?.bytes().await?.to_vec();
         let code = base64::decode(temp);
         match code {
             Ok(input) => {

src/state.rs

@@ -22,7 +22,7 @@ pub enum IFEXIT {
 
 pub(crate) type MyBackend = CrosstermBackend<Stdout>;
 //计划将它设置成一个入口
-pub fn run_app(terminal: &mut Terminal<MyBackend>) -> io::Result<()> {
+pub async fn run_app(terminal: &mut Terminal<MyBackend>) -> io::Result<()> {
     let mut appsub = AppSub::default();
     let informations = utils::start();
     if !informations.is_empty() {
@@ -46,7 +46,7 @@ pub fn run_app(terminal: &mut Terminal<MyBackend>) -> io::Result<()> {
     let mut pages: Vec<Box<dyn App>> = vec![Box::new(appsub), Box::new(appbar)];
 
     loop {
-        match pages[local_page as usize].run_app_local(terminal)? {
+        match pages[local_page as usize].run_app_local(terminal).await? {
             IFEXIT::Exit => return Ok(()),
             IFEXIT::Change(e) => local_page = e,
             IFEXIT::Next => {}

src/subscribe/appsub.rs

@@ -115,10 +115,12 @@ impl AppSub {
         self.index_subscription.select(None);
     }
 }
+use async_trait::async_trait;
+#[async_trait]
 impl App for AppSub {
-    fn run_app_local(&mut self, terminal: &mut Terminal<MyBackend>) -> io::Result<IFEXIT> {
+    async fn run_app_local(&mut self, terminal: &mut Terminal<MyBackend>) -> io::Result<IFEXIT> {
         terminal.draw(|f| ui(f, self))?;
-        subscribe_state(self)
+        subscribe_state(self).await
     }
 }
 impl Default for AppSub {

src/subscribe/state.rs

@@ -5,7 +5,7 @@ use super::{Page, IFEXIT};
 use crossterm::event::{self, Event, KeyCode};
 use std::{env, io, process::Command};
 use tui::widgets::ListState;
-pub(crate) fn subscribe_state(app: &mut AppSub) -> io::Result<IFEXIT> {
+pub(crate) async fn subscribe_state(app: &mut AppSub) -> io::Result<IFEXIT> {
     if let Event::Key(key) = event::read()? {
         match app.input_mode {
             InputMode::Normal => match key.code {
@@ -121,7 +121,7 @@ pub(crate) fn subscribe_state(app: &mut AppSub) -> io::Result<IFEXIT> {
                     utils::create_json_file(utils::Save::Subscribes, subscribe_json)
                         .unwrap_or_else(|err| panic!("{}", err));
                     //    .collect();
-                    let get_list = spider::get_the_key(app.subscription.clone());
+                    let get_list = spider::get_the_key(app.subscription.clone()).await;
                     if let Ok(list) = get_list {
                         if !list.is_empty(){
                             let mut storge: String = "[\n\n".to_string();