trait SinkQueueWithCancel[T] extends SinkQueue[T]
Ordering
- Alphabetic
- By Inheritance
Inherited
- SinkQueueWithCancel
- SinkQueue
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Abstract Value Members
-
abstract
def
cancel(): Unit
Cancel the stream.
Cancel the stream. This method returns right away without waiting for actual finalizing stream.
-
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.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.- Definition Classes
- SinkQueue