anchor.diff:  ----
   
   
  -== Imports for Examples
  +=== Imports for Examples
   All code examples assume the following imports:
   [source,scala,numbered]
   ----
  
positive.code:       println("Writing...")
        oomNewItemBatch.serially.flatMap(_.concurrently.map(item => write(item.id, item)))
      }
    } yield oomResult.forall(_ == true)
  }
  ----
  
  == Transforming and traversing collections using workers
  
  +s_mach.concurrent+ provides the +workers+ method which allows specifying the maximum number of concurrent operations.
  
  
negative.code:       println("Writing...")
        oomNewItemBatch.workers(2).flatMap(_.workers(4).map(item => write(item.id, item)))
      }
    } yield oomResult.forall(_ === true)
  }
  ----
  
  
  === Adding progress reporting, retry and throttle control to collection concurrent operations
  +s_mach.concurrent+ allows modifying collection concurrent operations (+serially+, +concurrently+ or +workers+) to
  report progress, retry failures and limit iteration speed to a specific time period.
  
  