diff --git a/src/app/mod.rs b/src/app/mod.rs index cf6b516..b1b7fba 100644 --- a/src/app/mod.rs +++ b/src/app/mod.rs @@ -86,7 +86,7 @@ impl App { } } } - transfer_event = self.event_listener.recv() => { + transfer_event = self.event_listener.recv().fuse() => { if let Some(event) = transfer_event { debug!("got transferr event {event:?}"); match event { diff --git a/src/main.rs b/src/main.rs index afcada2..06c2cfe 100644 --- a/src/main.rs +++ b/src/main.rs @@ -25,7 +25,7 @@ fn main() -> Result<()> { result } -#[tokio::main] +#[tokio::main(flavor = "multi_thread")] async fn start_and_run(terminal: &mut DefaultTerminal, config: Config) -> Result<()> { let (event_tx, event_listener) = unbounded_channel(); diff --git a/src/transfer.rs b/src/transfer.rs index a65ceba..8e7152f 100644 --- a/src/transfer.rs +++ b/src/transfer.rs @@ -377,7 +377,7 @@ pub struct UploadParams { token: String, } -pub async fn register_cancel( +pub async fn handle_cancel( Query(params): Query, State(service): State, ) -> impl IntoResponse {