class StatelyDB::Transaction::Queue

TransactionQueue is a wrapper around Thread::Queue that implements Enumerable

def each

Returns:
  • (void) -

Other tags:
    Yield: - Gives each element in the queue to the block. 
def each
  loop do
    yield pop
  end
end

def each_item

Returns:
  • (void) -

Other tags:
    Yield: - Gives each item in the queue to the block. 
def each_item
  loop do
    yield pop
  end
end

def initialize 

def initialize
  super
  @last_message_id = 0
end

def next_message_id

Returns:
  • (Integer) - 
def next_message_id
  @last_message_id += 1
end