streams.rs

use hannibal::prelude::*;

#[derive(Default, Actor)]
struct FizzBuzzer(&'static str);

impl StreamHandler<i32> for FizzBuzzer {
    async fn handle(&mut self, _ctx: &mut Context<Self>, msg: i32) {
        match (msg % 3 == 0, msg % 5 == 0) {
            (true, true) => {
                self.0 = "fizzbuzz";
                println!("{msg} -> {inner}", inner = self.0, msg = msg);
            }
            (true, false) => {
                self.0 = "fizz";
                println!("{msg} -> {inner}", inner = self.0, msg = msg);
            }
            (false, true) => {
                self.0 = "buzz";
                println!("{msg} -> {inner}", inner = self.0, msg = msg);
            }
            _ => {}
        }
    }
    async fn finished(&mut self, ctx: &mut Context<Self>) {
        ctx.stop().unwrap();
    }
}

#[hannibal::main]
async fn main() {
    let num_stream = futures::stream::iter(1..30);
    let addr = hannibal::setup_actor(FizzBuzzer::default())
        .on_stream(num_stream)
        .spawn();

    addr.await.unwrap();
}