Packages

trait SinkQueue[T] extends AnyRef

Trait allows to have the queue as a sink for some stream. "SinkQueue" pulls data from stream with backpressure mechanism.

Source
Queue.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
SinkQueueWithCancel
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SinkQueue
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def pull(): Future[Option[T]]

    Method pulls elements from stream and returns future that: - fails if stream is failed - completes with None in case if stream is completed - completes with Some(element) in case next element is available from stream.