diff options
| author | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-22 01:42:55 +0300 |
|---|---|---|
| committer | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-22 01:43:32 +0300 |
| commit | 27ff4ddf96b99db796374a4c68a62270ac1cb74f (patch) | |
| tree | fdb7cc73b8f21e6516160c301a57d50742e1c92b /src/server/headless.rs | |
| parent | bf752268660fc2c3cdcdc13920c014af250a5062 (diff) | |
fix: block idle client writer
refs #726
Diffstat (limited to 'src/server/headless.rs')
| -rw-r--r-- | src/server/headless.rs | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/server/headless.rs b/src/server/headless.rs index 35e17efe..0daa2444 100644 --- a/src/server/headless.rs +++ b/src/server/headless.rs @@ -4025,10 +4025,7 @@ mod tests { let (control_tx, control_rx) = std::sync::mpsc::channel(); let (render_tx, render_rx) = std::sync::mpsc::sync_channel(1); ( - ClientWriter { - control: control_tx, - render: render_tx, - }, + ClientWriter::test_channel(control_tx, render_tx), control_rx, render_rx, ) @@ -6308,7 +6305,7 @@ next_tab = "" .as_ref() .unwrap() .render - .send(queued) + .try_send(queued) .expect("pre-fill render queue"); assert!(server.handle_server_event(ServerEvent::ClientInput { @@ -6430,7 +6427,7 @@ next_tab = "" .expect("serialize dummy message"); client_tx .render - .send(queued) + .try_send(queued) .expect("pre-fill render queue"); server.clients.insert( @@ -6474,7 +6471,7 @@ next_tab = "" .expect("serialize dummy message"); client_tx .render - .send(queued) + .try_send(queued) .expect("pre-fill render queue"); server.clients.insert( @@ -6890,7 +6887,7 @@ next_tab = "" .as_ref() .unwrap() .render - .send(queued) + .try_send(queued) .expect("pre-fill render queue"); server.app.full_redraw_pending = true; |