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 QueueOps
  2. by any2stringadd
  3. by StringFormat
  4. by Ensuring
  5. 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(): [Option[T]]

    Pulls elements from the stream and returns a Future that: - fails if the stream is failed - completes with None in case the stream is completed - completes with Some(element) in case the next element is available from stream.

    Pulls elements from the stream and returns a Future that: - fails if the stream is failed - completes with None in case the stream is completed - completes with Some(element) in case the next element is available from stream.

    Definition Classes
    SinkQueue

Concrete Value Members

  1. def asJava: javadsl.SinkQueueWithCancel[T]
    Implicit
    This member is added by an implicit conversion from SinkQueueWithCancel[T] toQueueOps[T] performed by method QueueOps in akka.stream.scaladsl.SinkQueueWithCancel.
    Definition Classes
    QueueOps
  2. val queue: SinkQueueWithCancel[T]
    Implicit
    This member is added by an implicit conversion from SinkQueueWithCancel[T] toQueueOps[T] performed by method QueueOps in akka.stream.scaladsl.SinkQueueWithCancel.
    Definition Classes
    QueueOps