Sha256: 77844fbcf769f1483c4684492b29296a090477e77e96923b3478e6991da7ce32

Contents?: true

Size: 408 Bytes

Versions: 1

Compression:

Stored size: 408 Bytes

Contents

package s3.website

import s3.website.model.Config
import scala.collection.parallel.{ForkJoinTaskSupport, ParSeq}
import scala.concurrent.forkjoin.ForkJoinPool

class Utils(implicit config: Config) {
  def toParSeq[T](seq: Seq[T]): ParSeq[T] = {
    val parallelSeq: ParSeq[T] = seq.par
    parallelSeq.tasksupport_=(new ForkJoinTaskSupport(new ForkJoinPool(config.concurrency_level)))
    parallelSeq
  }
}

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
s3_website_monadic-0.0.3 src/main/scala/s3/website/Utils.scala