Added basic implementation of each method with its basic test, but it needs more tests, still working on it.

Author: dev123dev123

Ax.podspec

@@ -8,7 +8,7 @@
 
 Pod::Spec.new do |s|
   s.name             = 'Ax'
-  s.version          = '0.1.1'
+  s.version          = '0.1.2'
   s.summary          = 'Ax is a library written in Swift that helps you to control the flow of asynchronous executions in a simplified way.'
 
 # This description is used to generate tags and improve search results.

Ax.xcodeproj/project.xcworkspace/xcuserdata/wilsonbalderrama.xcuserdatad/UserInterfaceState.xcuserstate

@@ -13,6 +13,33 @@ final public class Ax {
   public typealias ResultClosure = (NSError?) -> Void
   public typealias DoneClosure = (NSError?) -> Void
   public typealias TaskClosure = (@escaping DoneClosure) -> Void
+  public typealias IterateeClosure<T> = (T, DoneClosure) -> Void
+  
+  public static func each<T>(collection: [T], iteratee: @escaping IterateeClosure<T>, result: @escaping ResultClosure) {
+    let group = DispatchGroup()
+    var errorFound: NSError?
+    
+    for item in collection {
+      group.enter()
+      
+      DispatchQueue.global(qos: .background).async {
+        iteratee(item) { error in
+          if let error = error {
+            errorFound = error
+            result(error)
+          }
+          
+          group.leave()
+        }
+      }
+    }
+    
+    group.notify(queue: DispatchQueue.global()) {
+      if errorFound == nil {
+        result(nil)
+      }
+    }
+  }
 
   public static func parallel(tasks: [TaskClosure], result: @escaping ResultClosure) {
     let group = DispatchGroup()

Ax/Ax.swift

@@ -32,6 +32,8 @@ class AxTests: XCTestCase {
     }
   }
 
+
+  
 
   // Serial tests
   func testRunningThreeTasksAndEnsureAreBeingCalledSerially() {
@@ -533,6 +535,30 @@ class AxTests: XCTestCase {
     }
   }
 
+  //Each tests
+  func testRunningAnArrayItemsInParallel() {
+    let ex = expectation(description: "")
+    let array = [0, 1, 2, 3]
+    
+    Ax.each(
+      collection: array,
+      iteratee: { item, done in
+        print(item)
+        done(nil)
+      },
+      result: { error in
+        XCTAssertNil(error)
+        ex.fulfill()
+      }
+    )
+    
+    waitForExpectations(timeout: 10) { (error) in
+      if let error = error {
+        XCTFail("error: \(error)")
+      }
+    }
+  }
+  
 
 
 }