diff --git a/src/lua/threads/runner.rs b/src/lua/threads/runner.rs index 6786971..5cf587a 100644 --- a/src/lua/threads/runner.rs +++ b/src/lua/threads/runner.rs @@ -3,10 +3,11 @@ use futures::Future; use futures::{channel::mpsc, sink::SinkExt}; use tokio::sync::RwLock; -pub async fn iter_futures(target_iter: Vec, target_function: F, workers: usize) +pub async fn iter_futures(target_iter: Vec, target_function: F, workers: usize) where F: FnOnce(T) -> Fut + Clone, Fut: Future, + T: Clone { stream::iter(target_iter) .for_each_concurrent(workers, |out| {