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.  def isSynchronous: Boolean

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

8.  val source: Self
9.  def syncFlatMap(f: (Ack) => Future[Ack])(implicit r: UncaughtExceptionReporter): 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 without any hard asynchronous boundaries — in case the source is an Ack value (e.g. Continue or Stop) then execution will be immediate, otherwise execution will be trampolined (being execute on Monix's TrampolineExecutionContext).

   WARN: in case the source is an Ack value (e.g. Continue or Stop) and the execution being immediate, with no async boundaries, this means that application of this function is *stack unsafe*!

   Use with great care as an optimization. Don't use it in tail-recursive loops!

   f

   is the mapping function used to transform the source

   r

   is an exception reporter used for reporting errors triggered by f

10.  def syncMap(f: (Ack) => Ack)(implicit r: UncaughtExceptionReporter): 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 without any hard asynchronous boundaries — in case the source is an Ack value (e.g. Continue or Stop) then execution will be immediate, otherwise execution will be trampolined (being execute on Monix's TrampolineExecutionContext).

    WARN: in case the source is an Ack value (e.g. Continue or Stop) and the execution being immediate, with no async boundaries, this means that application of this function is *stack unsafe*!

    Use with great care as an optimization. Don't use it in tail-recursive loops!

    f

    is the mapping function used to transform the source

    r

    is an exception reporter used for reporting errors triggered by f

11.  def syncOnComplete(f: (Try[Ack]) => Unit)(implicit r: UncaughtExceptionReporter): 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 without any hard asynchronous boundaries — in case the source is an Ack value (e.g. Continue or Stop) then execution will be immediate, otherwise execution will be trampolined (being execute on Monix's TrampolineExecutionContext).

    WARN: in case the source is an Ack value (e.g. Continue or Stop) and the execution being immediate, with no async boundaries, this means that application of this function is *stack unsafe*!

    Use with great care as an optimization. Don't use it in tail-recursive loops!

    r

    is a reporter for exceptions thrown by f

12.  def syncOnContinue(thunk: => Unit)(implicit r: UncaughtExceptionReporter): Self

    Executes the given callback on Continue.

    Executes the given callback on Continue.

    Execution will happen without any hard asynchronous boundaries — in case the source is an Ack value (e.g. Continue or Stop) then execution will be immediate, otherwise execution will be trampolined (being execute on Monix's TrampolineExecutionContext).

    WARN: in case the source is an Ack value (e.g. Continue or Stop) and the execution being immediate, with no async boundaries, this means that application of this function is *stack unsafe*!

    Use with great care as an optimization. Don't use it in tail-recursive loops!

    r

    is an exception reporter used for reporting errors triggered by thunk

13.  def syncOnContinueFollow[A](p: Promise[A], value: A): Self

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

14.  def syncOnStopFollow[A](p: Promise[A], value: A): Self

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

15.  def syncOnStopOrFailure(cb: (Option[Throwable]) => Unit)(implicit r: UncaughtExceptionReporter): Self

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

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

    Execution will happen without any hard asynchronous boundaries — in case the source is an Ack value (e.g. Continue or Stop) then execution will be immediate, otherwise execution will be trampolined (being execute on Monix's TrampolineExecutionContext).

    WARN: in case the source is an Ack value (e.g. Continue or Stop) and the execution being immediate, with no async boundaries, this means that application of this function is *stack unsafe*!

    Use with great care as an optimization. Don't use it in tail-recursive loops!

    r

    is an exception reporter used for reporting errors triggered by cb

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