Packages

object FutureQueue

Companion object for FutureQueue.

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

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 aggregate[A](queues: FutureQueue[_ <: A]*)(implicit executor: ExecutionContext): FutureQueue[A]

    Creates a new FutureQueue ('aggregate queue') to which all of the specified FutureQueues ('input queues') are drained.

    Creates a new FutureQueue ('aggregate queue') to which all of the specified FutureQueues ('input queues') are drained.

    Elements added to the input queues are dequeued from them and enqueued to the aggregate queue. Consequently, one SHOULD NOT invoke dequeue, drainContinually or drainToContinually on the input queues, or this method with any of the input queues as an argument, after calling this method; doing so will result in only some elements being enqueued to the aggregate queue, in an inconsistent fashion.

    Ordering is guaranteed to be maintained for elements added to a single input queue relative to each other. However, ordering of elements added to different input queues is not guaranteed relative to each other; they are enqueued into the aggregate queue only roughly in the order that they are enqueued into the input queues.

    A

    the type of the resulting FutureQueue

    queues

    the FutureQueues to aggregate into a single FutureQueue

    executor

    the ExecutionContext used to aggregate the queues

    returns

    a FutureQueue which aggregates elements added to the specified FutureQueues

  5. def apply[A](elems: A*): FutureQueue[A]

    Creates a FutureQueue with the specified elements.

    Creates a FutureQueue with the specified elements.

    elems

    the elements of the created FutureQueue

    returns

    a FutureQueue containing the specified elements

  6. def apply[A](elems: Queue[A]): FutureQueue[A]

    Creates a FutureQueue with the specified elements.

    Creates a FutureQueue with the specified elements.

    elems

    the elements of the created FutureQueue

    returns

    a FutureQueue containing the specified elements

  7. def apply[A](): FutureQueue[A]

    Creates an empty FutureQueue.

    Creates an empty FutureQueue.

    returns

    an empty FutureQueue

  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  10. def empty[A]: FutureQueue[A]

    Creates an empty FutureQueue.

    Creates an empty FutureQueue.

    returns

    an empty FutureQueue

  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  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. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    AnyRef → Any
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. object Implicits

    An object containing an implicit conversion from FutureQueue to Queue (deprecated).

    An object containing an implicit conversion from FutureQueue to Queue (deprecated).

    The implicit conversion is deprecated because it hides the mutability of the underlying FutureQueue. It could lead to invoking multiple methods from Queue on a FutureQueue and expecting them to be invoked on the same collection, which is not guaranteed.

    Annotations
    @deprecated
    Deprecated

    (Since version 1.1.0) convert to Queue explicitly instead

Inherited from AnyRef

Inherited from Any

Ungrouped