class ZQueueConsumer[E] extends AnyRef
- Alphabetic
- By Inheritance
- ZQueueConsumer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def cancellablePoll(timeout: zio.Duration): Option[E]
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
- timeout
how long to wait before giving up
- returns
the head of this queue wrapped in Some, or None if the specified waiting time elapses before an element is available
- Exceptions thrown
io.temporal.failure.CanceledFailureif surrounding io.temporal.workflow.CancellationScope is canceled while waiting
- def cancellableTake(): E
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
- returns
the head of this queue
- Exceptions thrown
io.temporal.failure.CanceledFailureif surrounding io.temporal.workflow.CancellationScope is canceled while waiting
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[R](f: (E) => R): ZQueueConsumer[R]
Returns a queue consisting of the results of applying the given function to the elements of this queue.
Returns a queue consisting of the results of applying the given function to the elements of this queue.
- f
a non-interfering, stateless function to apply to each element
- returns
the new queue backed by this one.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def peek(): Option[E]
Retrieves the head of this queue keeping it in the queue if it is not empty without blocking.
Retrieves the head of this queue keeping it in the queue if it is not empty without blocking.
- returns
the head of this queue wrapped in Some, or None if the queue is empty
- def poll(timeout: zio.Duration): Option[E]
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available. It is not unblocked in case of the enclosing CancellationScope cancellation. Use cancellablePoll instead.
- timeout
how long to wait before giving up.
- returns
the head of this queue wrapped in Some, or None if the specified waiting time elapses before an element is available
- def poll(): Option[E]
Retrieves and removes the head of this queue if it is not empty without blocking.
Retrieves and removes the head of this queue if it is not empty without blocking.
- returns
the head of this queue wrapped in Some, or None if the queue is empty
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def take(): E
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available. It is not unblocked in case of the enclosing * CancellationScope cancellation. Use cancellableTake instead.
- returns
the head of this queue
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)