1
0
Fork 0
mirror of https://github.com/Zedfrigg/ironbar.git synced 2025-07-01 10:41:03 +02:00

refactor(wayland): simplify task spawning code

This commit is contained in:
Jake Stanger 2024-01-14 15:42:07 +00:00
parent 963f8edc45
commit 18b47844f9
No known key found for this signature in database
GPG key ID: C51FC8F9CB0BEA61

View file

@ -3,7 +3,7 @@ mod wl_output;
mod wl_seat; mod wl_seat;
use crate::error::ERR_CHANNEL_RECV; use crate::error::ERR_CHANNEL_RECV;
use crate::{arc_mut, lock, register_client, send, Ironbar}; use crate::{arc_mut, lock, register_client, send, spawn, spawn_blocking};
use std::sync::{Arc, Mutex}; use std::sync::{Arc, Mutex};
use calloop_channel::Event::Msg; use calloop_channel::Event::Msg;
@ -132,7 +132,7 @@ impl Client {
#[cfg(feature = "clipboard")] #[cfg(feature = "clipboard")]
let clipboard_channel = broadcast::channel(32); let clipboard_channel = broadcast::channel(32);
Ironbar::runtime().spawn_blocking(move || { spawn_blocking(move || {
Environment::spawn(event_tx, request_rx, response_tx); Environment::spawn(event_tx, request_rx, response_tx);
}); });
@ -145,8 +145,7 @@ impl Client {
#[cfg(feature = "clipboard")] #[cfg(feature = "clipboard")]
let clipboard_tx = clipboard_channel.0.clone(); let clipboard_tx = clipboard_channel.0.clone();
let rt = Ironbar::runtime(); spawn(async move {
rt.spawn(async move {
while let Some(event) = event_rx.recv().await { while let Some(event) = event_rx.recv().await {
match event { match event {
Event::Output(event) => send!(output_tx, event), Event::Output(event) => send!(output_tx, event),