Function tiny_actor::actor::spawn_many

pub fn spawn_many<M, E, I, Fun, Fut>(
    iter: impl IntoIterator<Item = I>,
    config: Config,
    fun: Fun
) -> (ChildPool<E, Channel<M>>, Address<Channel<M>>) where
    Fun: FnOnce(I, Inbox<M>) -> Fut + Send + 'static + Clone,
    Fut: Future<Output = E> + Send + 'static,
    E: Send + 'static,
    M: Send + 'static,
    I: Send + 'static, 

Spawn a new actor with a multiple process, this returns a ChildPool and an Address.

The iterator will be passed along as the first argument to every spawned function.

Example

let (child_pool, address) =
    spawn_many(0..5, Config::default(), |i, mut inbox: Inbox<u32>| async move {
        loop {
            let msg = inbox.recv().await;
            println!("Received message on actor {i}: {msg:?}");
        }
    });