TheLanc3/lan-mouse
1
0
Fork 0
mirror of https://github.com/feschber/lan-mouse.git synced 2026-03-22 04:30:54 +03:00
Code Issues Packages Projects Releases Wiki Activity

Configurable emulation backend (#151)

Browse Source
This commit is contained in:
Ferdinand Schober
2024-07-01 20:09:16 +02:00
committed by GitHub
parent 9cbe1ed8d8
commit b6b16063a8
15 changed files with 417 additions and 179 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/server/emulation_task.rs
View File

@@ -8,7 +8,8 @@ use tokio::{
use crate::{
client::{ClientEvent, ClientHandle},
emulate::{self, InputEmulation},
config::EmulationBackend,
emulate::{self, error::EmulationCreationError, InputEmulation},
event::{Event, KeyboardEvent},
scancode,
server::State,
@@ -27,15 +28,16 @@ pub enum EmulationEvent {
}
pub fn new(
backend: Option<EmulationBackend>,
server: Server,
mut udp_rx: Receiver<Result<(Event, SocketAddr)>>,
sender_tx: Sender<(Event, SocketAddr)>,
capture_tx: Sender<CaptureEvent>,
timer_tx: Sender<()>,
) -> (JoinHandle<Result<()>>, Sender<EmulationEvent>) {
) -> Result<(JoinHandle<Result<()>>, Sender<EmulationEvent>), EmulationCreationError> {
let (tx, mut rx) = tokio::sync::mpsc::channel(32);
let emulate_task = tokio::task::spawn_local(async move {
let mut emulate = emulate::create().await;
let mut emulate = emulate::create(backend).await?;
let mut last_ignored = None;
loop {
@@ -75,7 +77,7 @@ pub fn new(
emulate.destroy().await;
anyhow::Ok(())
});
(emulate_task, tx)
Ok((emulate_task, tx))
}
async fn handle_udp_rx(