AckExtensions

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