class WebsocketRails::EventQueue

Attributes

queue[R]

Public Class Methods

new() click to toggle source
# File lib/websocket_rails/event_queue.rb, line 6
def initialize
  @queue = []
end

Public Instance Methods

<<(event)
Alias for: enqueue
enqueue(event) click to toggle source
# File lib/websocket_rails/event_queue.rb, line 10
def enqueue(event)
  @queue << event
end
Also aliased as: <<
flush(&block) click to toggle source
# File lib/websocket_rails/event_queue.rb, line 23
def flush(&block)
  unless block.nil?
    @queue.each do |item|
      block.call item
    end
  end
  @queue = []
end
last() click to toggle source
# File lib/websocket_rails/event_queue.rb, line 15
def last
  @queue.last
end
size() click to toggle source
# File lib/websocket_rails/event_queue.rb, line 19
def size
  @queue.size
end