cleanup

src/capture.rs

@@ -184,26 +184,33 @@ async fn do_capture(
     });
 
     /* create barriers for active clients */
-    for (handle, pos) in clients {
+    if let Err(e) = create_clients(&mut capture, clients, request_rx).await {
-        tokio::select! {
+        capture.terminate().await?;
-            r = capture.create(handle, to_capture_pos(pos)) => match r {
+        return Err(e.into());
-                Ok(_) => {},
-                Err(e) => {
-                    capture.terminate().await?;
-                    return Err(e.into());
-                },
-            },
-            _ = wait_for_termination(request_rx) => {
-                capture.terminate().await?;
-                return Ok(());
-            },
-        }
     }
 
-    let res = do_capture_session(active, &mut capture, conn, event_tx, request_rx, service).await;
+    if let Err(e) =
-    // FIXME replace with async drop when stabilized
+        do_capture_session(active, &mut capture, conn, event_tx, request_rx, service).await
-    capture.terminate().await?;
+    {
-    res
+        // FIXME replace with async drop when stabilized
+        capture.terminate().await?;
+        return Err(e);
+    }
+    Ok(())
+}
+
+async fn create_clients(
+    capture: &mut InputCapture,
+    clients: impl Iterator<Item = (CaptureHandle, lan_mouse_ipc::Position)>,
+    request_rx: &mut Receiver<CaptureRequest>,
+) -> Result<(), CaptureError> {
+    for (handle, pos) in clients {
+        tokio::select! {
+            r = capture.create(handle, to_capture_pos(pos)) => r?,
+            _ = wait_for_termination(request_rx) => return Ok(()),
+        }
+    }
+    Ok(())
 }
 
 async fn do_capture_session(