scalax.io

AsyncLongTraversable

class AsyncLongTraversable[+A] extends AnyRef

An additional API for LongTraversable for asynchronous interaction with the LongTraversable object.

This class is not a Traversable even though the name implies that, it is instead an API that provides asynchronous access to the LongTraversable.

Most of the blocking methods in LongTraversable (like foreach, find, fold) are in this class and returns Futures instead of blocking and returning the actual value like in LongTraversable.

While non-blocking methods like map, filter are not present in the Async API because those can be safely done with LongTraversable.

The following example illustrates a non-blocking

All methods in this class are performed asynchronously from the calling thread.

User: jeichar Date: 3/18/12 Time: 8:26 PM

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. AsyncLongTraversable
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AsyncLongTraversable(traversable: LongTraversable[A])(implicit executionContext: ExecutionContext)

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. def /:[B](z: B)(op: (B, A) ⇒ B): Future[B]

  5. def :\[B](z: B)(op: (A, B) ⇒ B): Future[B]

  6. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  7. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  8. def addString(b: StringBuilder): Future[StringBuilder]

  9. def addString(b: StringBuilder, sep: String): Future[StringBuilder]

  10. def addString(b: StringBuilder, start: String, sep: String, end: String): Future[StringBuilder]

  11. def aggregate[B](z: B)(seqop: (B, A) ⇒ B, combop: (B, B) ⇒ B): Future[B]

  12. def apply(idx: Long): Future[A]

  13. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  14. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  15. def collectFirst[B](pf: PartialFunction[A, B]): Future[Option[B]]

  16. def containsSlice[B](that: Seq[B], start: Long): Future[Boolean]

  17. def containsSlice[B](that: Seq[B]): Future[Boolean]

  18. def corresponds[B](that: LongTraversable[B])(p: (A, B) ⇒ Boolean): Future[Boolean]

  19. def corresponds[B](that: Seq[B])(p: (A, B) ⇒ Boolean): Future[Boolean]

  20. def count(p: (A) ⇒ Boolean): Future[Int]

  21. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  22. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  23. implicit val executionContext: ExecutionContext

  24. def exists(p: (A) ⇒ Boolean): Future[Boolean]

  25. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  26. def find(p: (A) ⇒ Boolean): Future[Option[A]]

  27. def fold[A1 >: A](z: A1)(op: (A1, A1) ⇒ A1): Future[A1]

  28. def foldLeft[B](z: B)(op: (B, A) ⇒ B): Future[B]

  29. def foldRight[B](z: B)(op: (A, B) ⇒ B): Future[B]

  30. def forall(p: (A) ⇒ Boolean): Future[Boolean]

  31. def foreach[U](f: (A) ⇒ U): Future[Unit]

  32. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  33. def groupBy[K](f: (A) ⇒ K): Future[Map[K, LongTraversable[A]]]

  34. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  35. def head: Future[A]

  36. def headOption: Future[Option[A]]

  37. def indexOf[B >: A](elem: B, from: Long): Future[Long]

  38. def indexOf[B >: A](elem: B): Future[Long]

  39. def isDefinedAt(idx: Long): Future[Boolean]

  40. def isEmpty: Future[Boolean]

  41. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  42. def last: Future[A]

  43. def lastIndexOf[B >: A](elem: B, end: Long): Future[Long]

  44. def lastIndexOf[B >: A](elem: B): Future[Long]

  45. def lastIndexWhere(p: (A) ⇒ Boolean, end: Long): Future[Long]

  46. def lastIndexWhere(p: (A) ⇒ Boolean): Future[Long]

  47. def lastOption: Future[Option[A]]

  48. def lcount(p: (A) ⇒ Boolean): Future[Long]

  49. def limitFold[U](init: U)(op: (U, A) ⇒ FoldResult[U]): Future[U]

  50. def lsize: Future[Long]

  51. def max[B >: A](implicit cmp: Ordering[B]): Future[A]

  52. def maxBy[B](f: (A) ⇒ B)(implicit cmp: Ordering[B]): Future[A]

  53. def min[B >: A](implicit cmp: Ordering[B]): Future[A]

  54. def minBy[B](f: (A) ⇒ B)(implicit cmp: Ordering[B]): Future[A]

  55. def mkString: Future[String]

  56. def mkString(sep: String): Future[String]

  57. def mkString(start: String, sep: String, end: String): Future[String]

  58. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  59. def nonEmpty: Future[Boolean]

  60. final def notify(): Unit

    Definition Classes
    AnyRef

  61. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  62. def prefixLength(p: (A) ⇒ Boolean): Future[Long]

  63. def product[B >: A](implicit num: Numeric[B]): Future[B]

  64. def reduce[A1 >: A](op: (A1, A1) ⇒ A1): Future[A1]

  65. def reduceLeft[B >: A](op: (B, A) ⇒ B): Future[B]

  66. def reduceLeftOption[B >: A](op: (B, A) ⇒ B): Future[Option[B]]

  67. def reduceOption[A1 >: A](op: (A1, A1) ⇒ A1): Future[Option[A1]]

  68. def reduceRight[B >: A](op: (A, B) ⇒ B): Future[B]

  69. def reduceRightOption[B >: A](op: (A, B) ⇒ B): Future[Option[B]]

  70. def sameElements[B >: A](that: LongTraversable[B]): Future[Boolean]

  71. def sameElements[B >: A](that: Iterable[B]): Future[Boolean]

  72. def segmentLength(p: (A) ⇒ Boolean, from: Long = 0): Future[Long]

  73. def size: Future[Int]

  74. def startsWith[B](that: Seq[B]): Future[Boolean]

  75. def startsWith[B](that: Seq[B], offset: Long): Future[Boolean]

  76. def startsWith[B](that: LongTraversable[B], offset: Long): Future[Boolean]

  77. def startsWith[B](that: LongTraversable[B]): Future[Boolean]

  78. def sum[B >: A](implicit num: Numeric[B]): Future[B]

  79. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  80. def toIndexedSeq[B >: A]: Future[IndexedSeq[A]]

  81. def toList: Future[List[A]]

  82. def toSeq: Future[Seq[A]]

  83. def toString(): String

    Definition Classes
    AnyRef → Any

  84. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  85. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  86. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from AnyRef

Inherited from Any

Ungrouped