Module: Synctest::Patches::QueuePatch

Defined in:

lib/synctest/patches.rb

Instance Method Summary

• #<<(object) ⇒ Object
• #clear ⇒ Object
• #close ⇒ Object
• #deq(non_block = false, timeout: nil) ⇒ Object
• #enq(object) ⇒ Object
• #initialize ⇒ Object
• #num_waiting ⇒ Object
• #pop(non_block = false, timeout: nil) ⇒ Object
• #push(object) ⇒ Object
• #shift(non_block = false, timeout: nil) ⇒ Object

Instance Method Details

#<<(object) ⇒ Object

# File 'lib/synctest/patches.rb', line 434

def <<(object)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_push(self, object)
end

#clear ⇒ Object

# File 'lib/synctest/patches.rb', line 448

def clear
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_clear(self)
end

#close ⇒ Object

# File 'lib/synctest/patches.rb', line 441

def close
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_close(self)
end

#deq(non_block = false, timeout: nil) ⇒ Object

# File 'lib/synctest/patches.rb', line 413

def deq(non_block = false, timeout: nil)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_pop(self, non_block, timeout)
end

#enq(object) ⇒ Object

# File 'lib/synctest/patches.rb', line 427

def enq(object)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_push(self, object)
end

#initialize ⇒ Object

# File 'lib/synctest/patches.rb', line 394

def initialize(...)
  super
  Synctest.associate(self)
end

#num_waiting ⇒ Object

# File 'lib/synctest/patches.rb', line 455

def num_waiting
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_num_waiting(self, super)
end

#pop(non_block = false, timeout: nil) ⇒ Object

# File 'lib/synctest/patches.rb', line 399

def pop(non_block = false, timeout: nil)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_pop(self, non_block, timeout)
end

#push(object) ⇒ Object

# File 'lib/synctest/patches.rb', line 420

def push(object)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_push(self, object)
end

#shift(non_block = false, timeout: nil) ⇒ Object

# File 'lib/synctest/patches.rb', line 406

def shift(non_block = false, timeout: nil)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.queue_pop(self, non_block, timeout)
end