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
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- SinkQueue
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Abstract Value Members
-
abstract
def
pull(): CompletionStage[Optional[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.