datomisca

TxReportQueue

Related Doc: package datomisca

final class TxReportQueue extends AnyVal

The data queue associated with a connection.

At any point in time either zero or one queue is associated with a connection.

This queue may be safely consumed from more than one thread. Note that the queue does not block producers, and will consume memory until you consume the elements from it.

Reports will be added to the queue at some point after the database has been updated. If the associated connection originated the transaction, the transaction future will be notified first, before a report is placed on this queue.

Source
TxReportQueue.scala
See also

datomic.Connection.txReportQueue()

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. TxReportQueue
  2. AnyVal
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TxReportQueue(queue: BlockingQueue[Map[_, _]])

    queue

    the underlying transaction report queue.

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  2. final def ##(): Int

    Definition Classes
    Any
  3. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to any2stringadd[TxReportQueue] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (TxReportQueue, B)

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to ArrowAssoc[TxReportQueue] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def drain(maxReports: Int): List[TxReport]

    Removes at most the given number of available transaction reports from this queue and returns them as a list.

    Removes at most the given number of available transaction reports from this queue and returns them as a list.

    This operation may be more efficient than repeatedly polling this queue.

    maxReports

    the maximum number of reports to transfer.

    returns

    a list of all available tranaction reports.

  8. def drain(): List[TxReport]

    Removes all available transaction reports from this queue and returns them as a list.

    Removes all available transaction reports from this queue and returns them as a list.

    This operation may be more efficient than repeatedly polling this queue.

    returns

    a list of all available tranaction reports.

  9. def ensuring(cond: (TxReportQueue) ⇒ Boolean, msg: ⇒ Any): TxReportQueue

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to Ensuring[TxReportQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  10. def ensuring(cond: (TxReportQueue) ⇒ Boolean): TxReportQueue

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to Ensuring[TxReportQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  11. def ensuring(cond: Boolean, msg: ⇒ Any): TxReportQueue

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to Ensuring[TxReportQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  12. def ensuring(cond: Boolean): TxReportQueue

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to Ensuring[TxReportQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  13. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to StringFormat[TxReportQueue] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  14. def getClass(): Class[_ <: AnyVal]

    Definition Classes
    AnyVal → Any
  15. def isEmpty(): Boolean

    Returns true if this queue contains no transaction reports.

    Returns true if this queue contains no transaction reports.

    returns

    true if this queue contains no transaction reports.

  16. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  17. def iterator(): Iterator[TxReport]

    Returns an iterator over the transaction reports in this queue.

    Returns an iterator over the transaction reports in this queue.

    returns

    an Iterator over the transaction reports in this queue.

  18. def peek(): Option[TxReport]

    Retrieves, but does not remove, the head of this queue, or None if this queue is empty.

    Retrieves, but does not remove, the head of this queue, or None if this queue is empty.

    returns

    the head of this queue, or None if this queue is empty.

  19. def poll(): Option[TxReport]

    Retrieves and removes the head of this queue, or returns None if this queue is empty.

    Retrieves and removes the head of this queue, or returns None if this queue is empty.

    returns

    the head of this queue, or None if this queue is empty.

  20. def poll(timeout: Duration): Option[TxReport]

    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.

    Throws InterruptedException if interrupted while waiting.

    timeout

    the duration of time to wait before giving up.

    returns

    the head of this queue, or None if the specified waiting time elapses before an element is available.

  21. val queue: BlockingQueue[Map[_, _]]

    the underlying transaction report queue.

  22. def size(): Int

    Returns the number of transaction reports in the queue.

    Returns the number of transaction reports in the queue.

    returns

    the number of transaction reports in the queue.

  23. def take(): TxReport

    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.

    Throws InterruptedException if interrupted while waiting.

    returns

    the head of this queue.

  24. def toString(): String

    Definition Classes
    Any
  25. def [B](y: B): (TxReportQueue, B)

    Implicit information
    This member is added by an implicit conversion from TxReportQueue to ArrowAssoc[TxReportQueue] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from AnyVal

Inherited from Any

Inherited by implicit conversion any2stringadd from TxReportQueue to any2stringadd[TxReportQueue]

Inherited by implicit conversion StringFormat from TxReportQueue to StringFormat[TxReportQueue]

Inherited by implicit conversion Ensuring from TxReportQueue to Ensuring[TxReportQueue]

Inherited by implicit conversion ArrowAssoc from TxReportQueue to ArrowAssoc[TxReportQueue]

Ungrouped