Collector

Attributes

See also

Future.awaitAll and Future.awaitFirst for simple usage of the collectors to get all results or the first succeeding one.

Example

// Sleep sort
val futs = numbers.map(i => Future(sleep(i.millis)))
val collector = Collector(futs*)
val output = mutable.ArrayBuffer[Int]()
for i <- 1 to futs.size:
 output += collector.results.read().await

Graph

Reset zoomHide graphShow graph

Supertypes

class Object

trait Matchable

class Any

Known subtypes

class MutableCollector[T]