case class Cons[A](head: A, tail: Future[Spool[A]]) extends Spool[A] with Product with Serializable
- Alphabetic
- By Inheritance
- Cons
- Serializable
- Product
- Equals
- Spool
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def ++[B >: A](that: => Future[Spool[B]]): Future[Spool[B]]
Concatenates two spools.
Concatenates two spools.
- Definition Classes
- Spool
- def ++[B >: A](that: => Spool[B]): Spool[B]
Concatenates two spools.
Concatenates two spools.
- Definition Classes
- Spool
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def collect[B](f: PartialFunction[A, B]): Future[Spool[B]]
The standard Scala collect, in order to implement map & filter.
The standard Scala collect, in order to implement map & filter.
It may seem unnatural to return a Future[…] here, but we cannot know whether the first element exists until we have applied its filter.
- Definition Classes
- Spool
- def concat[B >: A](that: Future[Spool[B]]): Future[Spool[B]]
- Definition Classes
- Spool
- See also
operator ++
- def concat[B >: A](that: Spool[B]): Spool[B]
- Definition Classes
- Spool
- See also
operator ++
- def distinctBy[B](fn: (A) => B): Spool[A]
Builds a new Spool from this one by filtering out duplicate elements, elements for which fn returns the same value.
Builds a new Spool from this one by filtering out duplicate elements, elements for which fn returns the same value.
NB: this has space consumption O(N) of the number of distinct items
- Definition Classes
- Spool
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def filter(f: (A) => Boolean): Future[Spool[A]]
- Definition Classes
- Spool
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def flatMap[B](f: (A) => Future[Spool[B]]): Future[Spool[B]]
Applies a function that generates a spool for each element in this spool, flattening the result into a single spool.
Applies a function that generates a spool for each element in this spool, flattening the result into a single spool.
- Definition Classes
- Spool
- def foldLeft[B](z: B)(f: (B, A) => B): Future[B]
- Definition Classes
- Spool
- def force: Future[Unit]
Eagerly executes all computation represented by this Spool (presumably for side-effects), and returns a Future representing its completion.
Eagerly executes all computation represented by this Spool (presumably for side-effects), and returns a Future representing its completion.
- Definition Classes
- Spool
- def foreach[B](f: (A) => B): Future[Unit]
Apply {{f}} for each item in the spool, until the end.
Apply {{f}} for each item in the spool, until the end. {{f}} is applied as the items become available.
- Definition Classes
- Spool
- def foreachElem[B](f: (Option[A]) => B): Future[Unit]
A version of {{foreach}} that wraps each element in an {{Option}}, terminating the stream (EOF) with {{None}}.
A version of {{foreach}} that wraps each element in an {{Option}}, terminating the stream (EOF) with {{None}}.
- Definition Classes
- Spool
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val head: A
The first element of the spool.
- def headOption: Option[A]
The first element of the spool if it is non-empty.
The first element of the spool if it is non-empty.
- Definition Classes
- Spool
- def isEmpty: Boolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[B](f: (A) => B): Spool[B]
- Definition Classes
- Spool
- def mapFuture[B](f: (A) => Future[B]): Future[Spool[B]]
Applies a function that generates a Future[B] for each element of this spool.
Applies a function that generates a Future[B] for each element of this spool. The returned future is satisfied when the head of the resulting spool is available.
- Definition Classes
- Spool
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def reduceLeft[B >: A](f: (B, A) => B): Future[B]
- Definition Classes
- Spool
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val tail: Future[Spool[A]]
The (deferred) tail of the spool.
- def take(n: Int): Spool[A]
Take the first n elements of the Spool as another Spool (adapted from Stream.take)
Take the first n elements of the Spool as another Spool (adapted from Stream.take)
- Definition Classes
- Spool
- def takeWhile(f: (A) => Boolean): Spool[A]
Take elements from the head of the Spool (lazily), while the given condition is true.
Take elements from the head of the Spool (lazily), while the given condition is true.
- Definition Classes
- Spool
- def toSeq: Future[Seq[A]]
Fully buffer the spool to a {{Seq}}.
Fully buffer the spool to a {{Seq}}. The returned future is satisfied when the entire result is ready.
- Definition Classes
- Spool
- def toString(): String
- Definition Classes
- Cons → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def zip[B](that: Spool[B]): Spool[(A, B)]
Zips two Spools returning a Spool of Tuple2s.