Packages

o

org.apache.pekko.dispatch

CompletionStages

object CompletionStages

CompletionStages provides utilities for working with CompletionStages.

Source
CompletionStages.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CompletionStages
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def asScala[T](stage: CompletionStage[T]): Future[T]

    Convert a CompletionStage to a Scala Future.

  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. def find[T <: AnyRef](stages: Iterable[_ <: CompletionStage[_ <: T]], predicate: Function[T, Boolean]): CompletionStage[Optional[T]]

    Return the first CompletionStage in the given Iterable that matches the given predicate.

    Return the first CompletionStage in the given Iterable that matches the given predicate. If no stage matches the predicate, an empty Optional is returned.

    stages

    the stages to search through

    predicate

    the predicate to apply to each completed stage

    returns

    a CompletionStage that, when completed, will contain an Optional with the first matching element, or an empty Optional if none matched

    Since

    1.2.0

  10. def firstCompletedOf[T <: AnyRef](stages: Iterable[_ <: CompletionStage[_ <: T]]): CompletionStage[T]

    Returns a new CompletionStage that, when completed, will contain the result of the first of the given stages to complete, with the same value or exception.

    Returns a new CompletionStage that, when completed, will contain the result of the first of the given stages to complete, with the same value or exception.

    If the given iterable is empty, the returned stage never completes.

    stages

    the stages

    returns

    a CompletionStage that, when completed, will contain the result of the first stage to complete with the same value or exception.

    Since

    1.2.0

  11. def fold[T <: AnyRef, R](zero: R, stages: Iterable[_ <: CompletionStage[_ <: T]], function: Function2[R, T, R]): CompletionStage[R]

    Aggregate the results of the given stages using the given associative function and a zero value.

    Aggregate the results of the given stages using the given associative function and a zero value. The stages are processed in the order they are given.

    zero

    the zero value

    stages

    the stages to aggregate

    function

    the associative function to use for aggregation

    returns

    a CompletionStage that, when completed, will contain the aggregated result

    Since

    1.2.0

  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  18. def reduce[T <: AnyRef, R >: T](stages: Iterable[_ <: CompletionStage[_ <: T]], function: Function2[R, T, R]): CompletionStage[R]

    Reduce the results of the given stages using the given associative function.

    Reduce the results of the given stages using the given associative function. The stages are processed in the order they are given. If the given iterable is empty, the returned stage is completed with a NoSuchElementException.

    stages

    the stages to reduce

    function

    the associative function to use for reduction

    returns

    a CompletionStage that, when completed, will contain the reduced result of the stages or a NoSuchElementException if the given iterable is empty

    Annotations
    @nowarn()
    Since

    1.2.0

  19. def sequence[T](stages: Iterable[_ <: CompletionStage[_ <: T]], executor: Executor): CompletionStage[List[T]]

    Transform a java.lang.Iterable of CompletionStages into a single CompletionStage with a java.util.List of all the results.

    Transform a java.lang.Iterable of CompletionStages into a single CompletionStage with a java.util.List of all the results. The stages are processed in the order they are given.

    stages

    the stages to sequence

    executor

    the executor to use for asynchronous execution, or null to use synchronous execution

    returns

    a CompletionStage that, when completed, will contain a java.util.List with all the results

    Since

    1.2.0

  20. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    AnyRef → Any
  22. def traverse[T, R](input: Iterable[T], function: Function[T, CompletionStage[R]], executor: Executor): CompletionStage[List[R]]

    Transform a java.lang.Iterable of CompletionStages into a single CompletionStage with a java.util.List of all the results.

    Transform a java.lang.Iterable of CompletionStages into a single CompletionStage with a java.util.List of all the results. The stages are processed in the order they are given.

    input

    the input iterable

    function

    the function to apply to each element

    executor

    the executor to use for asynchronous execution, or null to use synchronous execution

    returns

    a CompletionStage that, when completed, will contain a java.util.List with all the results

    Since

    1.2.0

  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped