implicit final class AsyncMapUnorderedIteratorOps[T] extends AnyVal
- Alphabetic
- By Inheritance
- AsyncMapUnorderedIteratorOps
- AnyVal
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new AsyncMapUnorderedIteratorOps(iterator: Iterator[T])
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
##(): Int
- Definition Classes
- Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
mapAsyncUnordered[R](parallelism: Int)(fn: (T) ⇒ Future[R])(implicit executionContext: ExecutionContext): Iterator[R]
Applies a function to all elements of an iterator and waits on the resulting futures.
Applies a function to all elements of an iterator and waits on the resulting futures. Up to
parallelism
futures are run at the same time, using the provided execution context. Elements are emitted as soon as they are ready, therefore it is possible that the transformed elements are not in the same order as in the input iterator.- parallelism
Number of futures running at the same time.
- fn
The function to apply.
- executionContext
The execution context.
-
def
toString(): String
- Definition Classes
- Any