Function malus::shared::launch_processing_task

pub(crate) fn launch_processing_task<X, F, U, Q, S>(
    spawner: &S,
    queue: Q,
    action: F,
)
where
    F: Fn(X) -> U + Send + 'static,
    U: Future<Output = ()> + Send + 'static,
    Q: Stream<Item = X> + Send + 'static,
    X: Send,
    S: 'static + SpawnNamed + Clone + Unpin,

Launch a service task for each item in the provided queue.