Class: Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/hrr_rb_ssh/compat.rb

Instance Method Summary collapse

Instance Method Details

#__deq__ ⇒ Object 



39
 
# File 'lib/hrr_rb_ssh/compat.rb', line 39

alias_method :__deq__, :deq

#__enq__ ⇒ Object 



38
 
# File 'lib/hrr_rb_ssh/compat.rb', line 38

alias_method :__enq__, :enq

#close ⇒ Object 



41
42
43
 
# File 'lib/hrr_rb_ssh/compat.rb', line 41

def close
  @closed = true
end

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


45
46
47
 
# File 'lib/hrr_rb_ssh/compat.rb', line 45

def closed?
  @closed == true
end

#deq ⇒ Object 



54
55
56
57
58
59
60
61
62
63
 
# File 'lib/hrr_rb_ssh/compat.rb', line 54

def deq
  begin
    Timeout.timeout(0.1) do
      __deq__
    end
  rescue Timeout::Error
    return nil if @closed == true
    retry
  end
end

#enq(arg) ⇒ Object

Raises:



49
50
51
52
 
# File 'lib/hrr_rb_ssh/compat.rb', line 49

def enq arg
  raise ClosedQueueError if @closed == true
  __enq__ arg
end