Value Members

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

   Definition Classes

   Any

2.  final def ##(): Int

   Definition Classes

   Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def getClass(): Class[_ <: AnyVal]

   Definition Classes

   AnyVal → Any

6.  final def isInstanceOf[T0]: Boolean

   Definition Classes

   Any

7.  macro def isSynchronous: Boolean

   Returns true if self is a direct reference to Continue or Stop, false otherwise.

8.  val source: Self
9.  macro def syncFlatMap(f: (Ack) ⇒ Future[Ack])(implicit s: Scheduler): Future[Ack]

   Given a mapping function, returns a new future reference that is the result of a flatMap operation applied to the source.

   Given a mapping function, returns a new future reference that is the result of a flatMap operation applied to the source.

   Execution will happen synchronously if the source value is a direct reference to Continue or Stop, or asynchronously otherwise.

10.  macro def syncMap(f: (Ack) ⇒ Ack)(implicit s: Scheduler): Future[Ack]

    Given a mapping function, returns a new future reference that is the result of a map operation applied to the source.

    Given a mapping function, returns a new future reference that is the result of a map operation applied to the source.

    Execution will happen synchronously if the source value is a direct reference to Continue or Stop, or asynchronously otherwise.

11.  macro def syncOnComplete(f: (Try[Ack]) ⇒ Unit)(implicit s: Scheduler): Unit

    When the source future is completed, either through an exception, or a value, apply the provided function.

    When the source future is completed, either through an exception, or a value, apply the provided function.

    Execution will happen synchronously if the source value is a direct reference to Continue or Stop, or asynchronously otherwise.

12.  macro def syncOnContinue(callback: ⇒ Unit)(implicit s: Scheduler): Self

    Executes the given callback on Continue.

    Executes the given callback on Continue.

    Execution will happen synchronously if the source value is a direct reference to Continue or Stop, or asynchronously otherwise.

13.  def syncOnContinueFollow[T](p: Promise[T], value: T)(implicit s: Scheduler): Self

    If the source completes with a Stop, then complete the given promise with a value.

14.  def syncOnStopFollow[T](p: Promise[T], value: T)(implicit s: Scheduler): Self

    If the source completes with a Stop, then complete the given promise with a value.

15.  macro def syncOnStopOrFailure(callback: ⇒ Unit)(implicit s: Scheduler): Self

    Executes the given callback on Stop or on Failure(ex).

    Executes the given callback on Stop or on Failure(ex).

    Execution will happen synchronously if the source value is a direct reference to Continue or Stop, or asynchronously otherwise.

16.  def syncTryFlatten(implicit r: UncaughtExceptionReporter): Future[Ack]

    Tries converting an already completed Future[Ack] into a direct reference to Continue or Stop.

    Tries converting an already completed Future[Ack] into a direct reference to Continue or Stop. Useful for collapsing async pipelines.

17.  def toString(): String

    Definition Classes

    Any