Implement Dart to Rust Stream

[rohitsangwan01]

Right now we have Support for Rust to Dart Stream updates,
it would be great if this plugin support opposite, Dart to Rust stream, i tried implementing this thanks to this issue, posting snippet here, might be usefull for others

pub use tokio::sync::mpsc::{self, Receiver, Sender};

// Define Macro for ChannelWrappers
macro_rules! create_channel_wrapper {
    ($name:ident, $type:ty) => {
        pub struct SenderWrapper(Sender<$type>);
        pub struct ReceiverWrapper(Receiver<$type>);

        impl SenderWrapper {
            pub async fn send(&self, data: $type) {
                if let Err(err) = self.0.send(data).await {
                    log::error!("Failed to send event {err}");
                }
            }
        }

        pub fn $name() -> (SenderWrapper, ReceiverWrapper) {
            let channel = channel::<$type>(256);
            (SenderWrapper(channel.0), ReceiverWrapper(channel.1))
        }
    };
}

// Create Channel
create_channel_wrapper!(create_u8_channel, Vec<u8>);

// Pass Receiver from dart to rust, and listen for updates
pub async fn test_method(rx: ReceiverWrapper) {
    let mut receiver = rx.0;
    while let Some(data) = receiver.recv().await {
        log::info!("Data From Dart: {data:?}")
    }
}

from Dart side

var (sender, receiver) = await createU8Channel();

// Pass receiver to rust
testMethod(receiver);

// Send updates to receiver
sender.send(data: [1, 2, 3, 4]);

[fzyzcjy]

Looks great! Btw, for future readers, it seems we can slightly generalize this method by creating a macro, then we can use this method whenever we want with one extra line of code (i.e. call macro).

[rohitsangwan01]

@fzyzcjy updated snippet with Macro example

[fzyzcjy]

Looks great!

P.S. Depending on the need, it seems possible to generalize more (for example, auto create that $name, auto postfix SenderWrapper/ReceiverWrapper to avoid collision when multi types, etc) for users that need it.