class SpoolSource[A] extends AnyRef

A SpoolSource is a simple object for creating and populating a Spool-chain. apply() returns a Future[Spool] that is populated by calls to offer(). This class is thread-safe.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SpoolSource
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SpoolSource()
  2. new SpoolSource(interruptHandler: PartialFunction[Throwable, Unit])

    interruptHandler

    attached to every Promise in the produced Spool.

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 apply(): Future[Spool[A]]

    Gets the current outstanding Future for the next Spool value.

    Gets the current outstanding Future for the next Spool value. The returned Spool will see all future values passed to offer(), up until close() is called. Previous values passed to offer() will not be seen in the Spool.

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  7. final def close(): Unit

    Closes this SpoolSource, which also terminates the generated Spool.

    Closes this SpoolSource, which also terminates the generated Spool. This method is idempotent.

  8. val closed: Future[Unit]

    Fulfilled when this SpoolSource has been closed or an exception is raised.

  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def offer(value: A): Unit

    Puts a value into the spool.

    Puts a value into the spool. Unless this SpoolSource has been closed, the current Future[Spool[A]] value will be fulfilled with a Spool that contains the provided value. If the SpoolSource has been closed, then this value is ignored. If multiple threads call offer simultaneously, the operation is thread-safe but the resulting order of values in the spool is non-deterministic.

  19. final def offerAndClose(value: A): Unit

    Puts a value into the spool and closes this SpoolSource.

    Puts a value into the spool and closes this SpoolSource. Unless this SpoolSource has been closed, the current Future[Spool[A]] value will be fulfilled with value *:: Future.value(Spool.empty[A]). If the SpoolSource has been closed, then this value is ignored. If multiple threads call offer simultaneously, the operation is thread-safe but the resulting order of values in the spool is non-deterministic.

  20. final def raise(e: Throwable): Unit

    Raises exception on this SpoolSource, which also terminates the generated Spool.

    Raises exception on this SpoolSource, which also terminates the generated Spool. This method is idempotent.

  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped