trait SourceQueue[T] extends AnyRef
This trait allows to have the queue as a data source for some stream.
- Source
- Queue.scala
- Alphabetic
- By Inheritance
- SourceQueue
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
offer(elem: T): CompletionStage[QueueOfferResult]
Method offers next element to a stream and returns future that: - completes with
Enqueued
if element is consumed by a stream - completes withDropped
when stream dropped offered element - completes withQueueClosed
when stream is completed during future is active - completes withFailure(f)
when failure to enqueue element from upstream - fails when stream is completedMethod offers next element to a stream and returns future that: - completes with
Enqueued
if element is consumed by a stream - completes withDropped
when stream dropped offered element - completes withQueueClosed
when stream is completed during future is active - completes withFailure(f)
when failure to enqueue element from upstream - fails when stream is completedAdditionally when using the backpressure overflowStrategy: - If the buffer is full the Future won't be completed until there is space in the buffer - Calling offer before the Future is completed in this case will return a failed Future
- elem
element to send to a stream
-
abstract
def
watchCompletion(): CompletionStage[Done]
Method returns a CompletionStage that will be completed if this operator completes, or will be failed when the stream is failed.