Class: OnStomp::OpenURI::MessageQueue

Inherits:

Object

• Object
• OnStomp::OpenURI::MessageQueue

show all

Defined in:

lib/onstomp/open-uri/message_queue.rb

Overview

Instance Method Summary (collapse)

• - (MessageQueue) initialize constructor

  A new instance of MessageQueue.

• - (Object) push(msg) (also: #<<)

  Puts a new object into the queue.

• - (Object) shift

  Waits until the queue contains at least one element, then takes it out and returns it.

6
7
8
9
10

# File 'lib/onstomp/open-uri/message_queue.rb', line 6

def initialize
  @queue = []
  @queue.extend MonitorMixin
  @empty_check = @queue.new_cond
end

19
20
21

# File 'lib/onstomp/open-uri/message_queue.rb', line 19

def push msg
  put_in_queue :push, msg
end

14
15
16

# File 'lib/onstomp/open-uri/message_queue.rb', line 14

def shift
  take_from_queue :shift
end