This commit is contained in:
Joe Ardent 2025-08-08 13:56:50 -07:00
parent cb071f4a7c
commit e55c7d6d05
3 changed files with 3 additions and 3 deletions

View file

@ -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 { if let Some(event) = transfer_event {
debug!("got transferr event {event:?}"); debug!("got transferr event {event:?}");
match event { match event {

View file

@ -25,7 +25,7 @@ fn main() -> Result<()> {
result result
} }
#[tokio::main] #[tokio::main(flavor = "multi_thread")]
async fn start_and_run(terminal: &mut DefaultTerminal, config: Config) -> Result<()> { async fn start_and_run(terminal: &mut DefaultTerminal, config: Config) -> Result<()> {
let (event_tx, event_listener) = unbounded_channel(); let (event_tx, event_listener) = unbounded_channel();

View file

@ -377,7 +377,7 @@ pub struct UploadParams {
token: String, token: String,
} }
pub async fn register_cancel( pub async fn handle_cancel(
Query(params): Query<CancelParams>, Query(params): Query<CancelParams>,
State(service): State<JocalService>, State(service): State<JocalService>,
) -> impl IntoResponse { ) -> impl IntoResponse {