c

com.twitter.concurrent

AbstractOffer

abstract class AbstractOffer[T] extends Offer[T]

Abstract Offer class for Java compatibility.

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AbstractOffer
  2. Offer
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AbstractOffer()

Abstract Value Members

  1. abstract def prepare(): Future[Tx[T]]

    Prepare a new transaction.

    Prepare a new transaction. This is the first stage of the 2 phase commit. This is typically only called by the offer implementation directly or by combinators.

    Definition Classes
    Offer

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def ?: Future[T]

    Alias for synchronize.

    Alias for synchronize.

    Definition Classes
    Offer
  5. def ??: T

    Synchronize, blocking for the result.

    Synchronize, blocking for the result.

    Definition Classes
    Offer
  6. def andThen(f: => Unit): Unit

    Synchronize (discarding the value), and then invoke the given closure.

    Synchronize (discarding the value), and then invoke the given closure. Convenient for loops.

    Definition Classes
    Offer
  7. def apply[U](f: (T) => U): Offer[U]

    Synonym for map().

    Synonym for map(). Useful in combination with Offer.choose() and Offer.select()

    Definition Classes
    Offer
  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  10. def const[U](f: => U): Offer[U]

    Like {{map}}, but to a constant (call-by-name).

    Like {{map}}, but to a constant (call-by-name).

    Definition Classes
    Offer
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  14. def foreach(f: (T) => Unit): Unit

    Synchronize on this offer indefinitely, invoking the given {{f}} with each successfully synchronized value.

    Synchronize on this offer indefinitely, invoking the given {{f}} with each successfully synchronized value. A receiver can use this to enumerate over all received values.

    Definition Classes
    Offer
  15. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. def map[U](f: (T) => U): Offer[U]

    Map this offer of type {{T}} into one of type {{U}}.

    Map this offer of type {{T}} into one of type {{U}}. The translation (performed by {{f}}) is done after the {{Offer[T]}} has successfully synchronized.

    Definition Classes
    Offer
  19. def mapConst[U](c: U): Offer[U]

    Java-friendly analog of const().

    Java-friendly analog of const().

    Definition Classes
    Offer
  20. def mapConstFunction[U](f: => U): Offer[U]

    Java-friendly analog of const().

    Java-friendly analog of const().

    Definition Classes
    Offer
  21. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. def or[U](other: Offer[U]): Offer[Either[T, U]]
    Definition Classes
    Offer
  25. def orElse[U >: T](other: Offer[U]): Offer[U]

    An offer that, when synchronized, attempts to synchronize {{this}} immediately, and if it fails, synchronizes on {{other}} instead.

    An offer that, when synchronized, attempts to synchronize {{this}} immediately, and if it fails, synchronizes on {{other}} instead. This is useful for providing default values. Eg.:

    offer orElse Offer.const { computeDefaultValue() }
    Definition Classes
    Offer
  26. def sync(): Future[T]

    Synchronizes this offer, returning a future representing the result of the synchronization.

    Synchronizes this offer, returning a future representing the result of the synchronization.

    Definition Classes
    Offer
  27. def syncWait(): T

    Synchronize this offer, blocking for the result.

    Synchronize this offer, blocking for the result. See {{sync()}} and {{com.twitter.util.Future.apply()}}

    Definition Classes
    Offer
  28. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    AnyRef → Any
  30. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  31. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  32. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Deprecated Value Members

  1. def apply(): Future[T]

    Synonym for sync()

    Synonym for sync()

    Definition Classes
    Offer
    Annotations
    @deprecated
    Deprecated

    (Since version 5.x) use sync() instead

Inherited from Offer[T]

Inherited from AnyRef

Inherited from Any

Ungrouped