trait SinkQueueWithCancel[T] extends SinkQueue[T]

This trait adds cancel support to SinkQueue.

Source
Queue.scala
Linear Supertypes
SinkQueue[T], AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SinkQueueWithCancel
  2. SinkQueue
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def cancel(): Unit

    Cancels the stream.

    Cancels the stream. This method returns right away without waiting for actual finalizing the stream.

  2. abstract def pull(): [Optional[T]]

    Pulls elements from the stream and returns a CompletionStage that: - fails if the stream is failed - completes with Empty in case the stream is completed - completes with element in case the next element is available from the stream.

    Pulls elements from the stream and returns a CompletionStage that: - fails if the stream is failed - completes with Empty in case the stream is completed - completes with element in case the next element is available from the stream.

    Definition Classes
    SinkQueue