feat: use calloop channel instead thread

then I can receive the events any time

Author: Decodetalkers

iced_layershell/src/multi_window.rs

@@ -65,7 +65,8 @@ where
     P::Message: 'static + TryInto<LayershellCustomActionWithId, Error = P::Message>,
 {
     use futures::task;
-    let (message_sender, message_receiver) = std::sync::mpsc::channel::<Action<P::Message>>();
+    use layershellev::calloop::channel::channel;
+    let (message_sender, message_receiver) = channel::<Action<P::Message>>();
 
     let boot_span = iced_debug::boot();
     let proxy = IcedProxy::new(message_sender);

iced_layershell/src/proxy.rs

@@ -5,13 +5,13 @@ use futures::{
 };
 use iced_graphics::shell;
 use iced_runtime::{Action, window};
+use layershellev::calloop::channel::Sender as WlSender;
 use std::pin::Pin;
-use std::sync::mpsc as stdmpsc;
 
 /// An event loop proxy that implements `Sink`.
 /// NOTE: not proxy anything now
 #[derive(Debug)]
-pub struct IcedProxy<Message: 'static>(stdmpsc::Sender<Message>);
+pub struct IcedProxy<Message: 'static>(WlSender<Message>);
 
 impl<Message: 'static> Clone for IcedProxy<Message> {
     fn clone(&self) -> Self {
@@ -20,7 +20,7 @@ impl<Message: 'static> Clone for IcedProxy<Message> {
 }
 
 impl<T: 'static> IcedProxy<T> {
-    pub fn new(sender: stdmpsc::Sender<T>) -> Self {
+    pub fn new(sender: WlSender<T>) -> Self {
         Self(sender)
     }
     #[allow(unused)]

iced_sessionlock/src/multi_window.rs

@@ -56,8 +56,9 @@ where
     P::Message: 'static + TryInto<UnLockAction, Error = P::Message>,
 {
     use futures::task;
+    use sessionlockev::calloop::channel::channel;
 
-    let (message_sender, message_receiver) = std::sync::mpsc::channel::<Action<P::Message>>();
+    let (message_sender, message_receiver) = channel::<Action<P::Message>>();
     let boot_span = debug::boot();
     let proxy = IcedProxy::new(message_sender);
 

iced_sessionlock/src/proxy.rs

@@ -6,13 +6,13 @@ use futures::{
 use iced_graphics::shell;
 
 use iced_runtime::{Action, window};
+use sessionlockev::calloop::channel::Sender as WlSender;
 use std::pin::Pin;
-use std::sync::mpsc as stdmpsc;
 
 /// An event loop proxy that implements `Sink`.
 /// NOTE: not proxy anything now
 #[derive(Debug)]
-pub struct IcedProxy<Message: 'static>(stdmpsc::Sender<Message>);
+pub struct IcedProxy<Message: 'static>(WlSender<Message>);
 
 impl<Message: 'static> Clone for IcedProxy<Message> {
     fn clone(&self) -> Self {
@@ -21,7 +21,7 @@ impl<Message: 'static> Clone for IcedProxy<Message> {
 }
 
 impl<T: 'static> IcedProxy<T> {
-    pub fn new(sender: stdmpsc::Sender<T>) -> Self {
+    pub fn new(sender: WlSender<T>) -> Self {
         Self(sender)
     }
     #[allow(unused)]