scalaz.concurrent.Future

BindSuspend

case class BindSuspend[A, B](thunk: () ⇒ Future[A], f: (A) ⇒ Future[B]) extends Future[B] with Product with Serializable

Source
Future.scala
Linear Supertypes
Serializable, Serializable, Product, Equals, Future[B], AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. BindSuspend
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. Future
  7. AnyRef
  8. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new BindSuspend(thunk: () ⇒ Future[A], f: (A) ⇒ Future[B])

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

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

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  9. val f: (A) ⇒ Future[B]

  10. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. def flatMap[B](f: (B) ⇒ Future[B]): Future[B]

    Definition Classes
    Future
  12. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  13. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  14. def listen(cb: (B) ⇒ Free.Trampoline[Unit]): Unit

    Run this computation to obtain an A, then invoke the given callback.

    Run this computation to obtain an A, then invoke the given callback. Also see runAsync.

    Definition Classes
    Future
  15. def listenInterruptibly(cb: (B) ⇒ Free.Trampoline[Unit], cancel: AtomicBoolean): Unit

    Run this computation to obtain an A, so long as cancel remains false.

    Run this computation to obtain an A, so long as cancel remains false. Because of trampolining, we get frequent opportunities to cancel while stepping through the trampoline, so this should provide a fairly robust means of cancellation.

    Definition Classes
    Future
  16. def map[B](f: (B) ⇒ B): Future[B]

    Definition Classes
    Future
  17. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  18. final def notify(): Unit

    Definition Classes
    AnyRef
  19. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  20. def run: B

    Run this Future and block awaiting its result.

    Run this Future and block awaiting its result.

    Definition Classes
    Future
  21. def runAsync(cb: (B) ⇒ Unit): Unit

    Run this Future, passing the result to the given callback once available.

    Run this Future, passing the result to the given callback once available. Any pure, non-asynchronous computation at the head of this Future will be forced in the calling thread. At the first Async encountered, control switches to whatever thread backs the Async and this function returns.

    Definition Classes
    Future
  22. def runAsyncInterruptibly(cb: (B) ⇒ Unit, cancel: AtomicBoolean): Unit

    Run this computation to obtain an A, so long as cancel remains false.

    Run this computation to obtain an A, so long as cancel remains false. Because of trampolining, we get frequent opportunities to cancel while stepping through the trampoline, this should provide a fairly robust means of cancellation.

    Definition Classes
    Future
  23. def start: Future[B]

    Begins running this Future and returns a new future that blocks waiting for the result.

    Begins running this Future and returns a new future that blocks waiting for the result. Note that this results

    Definition Classes
    Future
  24. final def step: Future[B]

    Evaluate this Future to a result, or another asynchronous computation.

    Evaluate this Future to a result, or another asynchronous computation. This has the effect of stripping off any 'pure' trampolined computation at the start of this Future.

    Definition Classes
    Future
    Annotations
    @tailrec()
  25. final def stepInterruptibly(cancel: AtomicBoolean): Future[B]

    Like step, but may be interrupted by setting cancel to true.

    Like step, but may be interrupted by setting cancel to true.

    Definition Classes
    Future
    Annotations
    @tailrec()
  26. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  27. val thunk: () ⇒ Future[A]

  28. def timed(timeoutInMillis: Long): Future[\/[Throwable, B]]

    Returns a Future which returns a TimeoutException after timeoutInMillis, and attempts to cancel the running computation.

    Returns a Future which returns a TimeoutException after timeoutInMillis, and attempts to cancel the running computation. This implementation will not block the future's execution thread

    Definition Classes
    Future
  29. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  31. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from Future[B]

Inherited from AnyRef

Inherited from Any

Ungrouped