class Queue

Public Instance Methods

__deq__()
Alias for: deq
__enq__(arg)
Alias for: enq
close() click to toggle source
# File lib/hrr_rb_ssh/compat/ruby/queue.rb, line 14
def close
  @closed = true
end
closed?() click to toggle source
# File lib/hrr_rb_ssh/compat/ruby/queue.rb, line 18
def closed?
  @closed == true
end
deq() click to toggle source
# File lib/hrr_rb_ssh/compat/ruby/queue.rb, line 27
def deq
  begin
    Timeout.timeout(0.1) do
      __deq__
    end
  rescue Timeout::Error
    return nil if @closed == true
    retry
  end
end
Also aliased as: __deq__
enq(arg) click to toggle source
# File lib/hrr_rb_ssh/compat/ruby/queue.rb, line 22
def enq arg
  raise ClosedQueueError if @closed == true
  __enq__ arg
end
Also aliased as: __enq__