akka.dataflow

DataflowPromise

implicit final class DataflowPromise[T] extends AnyVal

Linear Supertypes
AnyVal, NotNull, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. DataflowPromise
  2. AnyVal
  3. NotNull
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DataflowPromise(promise: Promise[T])

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  2. final def ##(): Int

    Definition Classes
    Any
  3. final def <<(other: Promise[T])(implicit ec: ExecutionContext): scala.concurrent.Future[T] @scala.util.continuations.cpsParam[scala.concurrent.Future[Any],scala.concurrent.Future[Any]]

    Completes this Promise with the value of the specified Promise when/if it completes.

    Completes this Promise with the value of the specified Promise when/if it completes.

    other

    The Promise whose value will be transferred to this Promise upon completion

    ec

    An ExecutionContext which will be used to execute callbacks registered in this method

    returns

    A Future representing the result of this operation

  4. final def <<(other: Future[T])(implicit ec: ExecutionContext): scala.concurrent.Future[T] @scala.util.continuations.cpsParam[scala.concurrent.Future[Any],scala.concurrent.Future[Any]]

    Completes this Promise with the value of the specified Future when/if it completes.

    Completes this Promise with the value of the specified Future when/if it completes.

    other

    The Future whose value will be transferred to this Promise upon completion

    ec

    An ExecutionContext which will be used to execute callbacks registered in this method

    returns

    A Future representing the result of this operation

  5. final def <<(value: T): scala.concurrent.Future[T] @scala.util.continuations.cpsParam[scala.concurrent.Future[Any],scala.concurrent.Future[Any]]

    Completes the Promise with the specified value or throws an exception if already completed.

    Completes the Promise with the specified value or throws an exception if already completed. See Promise.success(value) for semantics.

    value

    The value which denotes the successful value of the Promise

    returns

    This Promise's Future

  6. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  7. final def apply()(implicit ec: ExecutionContext): T @scala.util.continuations.cpsParam[scala.concurrent.Future[Any],scala.concurrent.Future[Any]]

    For use only within a flow block or another compatible Delimited Continuations reset block.

    For use only within a flow block or another compatible Delimited Continuations reset block.

    Returns the result of this Promise without blocking, by suspending execution and storing it as a continuation until the result is available.

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  9. def getClass(): Class[_ <: AnyVal]

    Definition Classes
    AnyVal → Any
  10. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  11. val promise: Promise[T]

  12. def toString(): String

    Definition Classes
    Any

Inherited from AnyVal

Inherited from NotNull

Inherited from Any

Ungrouped