Async component

Zero overhead reactive programming

Example

See async_component/examples/example.rs for simple example.

See examples/gui-demo project for example using with gui(winit, raqote, pixels).

Code

use async_component::AsyncComponent;

#[derive(Debug, AsyncComponent)]
struct CounterComponent {
    // State must be wrapped with StateCell
    #[state(Self::on_counter_update)]
    counter: StateCell<i32>,

    // Stream
    // It iterates every queued items in single poll to prevent slowdown.
    // If the stream is immediate and resolves indefinitely, the task will fall to infinite loop. See expanded code below.
    #[stream(Self::on_counter_recv)]
    counter_recv: Receiver<i32>,
}

impl CounterComponent {
    fn on_counter_update(&mut self) {
        println!("Counter updated to: {}", *self.counter);
    }

    fn on_counter_recv(&mut self, counter: i32) {
        *self.sub_component.counter = counter;
    }
}

Running this component stream will print initial value first and print changed value if new values are sent through channel.

Counter updated to: 0
Counter updated to: ...

Expanded

Component derive macro will generate AsyncComponent trait implementation for CounterComponent like below.

impl AsyncComponent for CounterComponent {
    fn poll_next_state(self: Pin<&mut Self>, cx: &mut Context) -> Poll<()> {
        let mut result = Poll::Pending;

        if StateCell::poll_state(
            Pin::new(&mut self.counter),
            cx
        ) {
            Self::on_counter_update(&mut self);

            if result.is_pending() {
                result = Poll::Ready(());
            }
        }

       result
    }

    fn poll_next_stream(self: Pin<&mut Self>, cx: &mut Context) -> Poll<()> {
        let mut result = Poll::Pending;

        if let Poll::Ready(Some(recv)) = Stream::poll_next(Pin::new(&mut self.counter_recv), cx) {
            Self::on_counter_recv(&mut self, recv);

            if result.is_pending() {
                result = Poll::Ready(());
            }
        }

        result
    }
}