Class: LS4::HTTPGatewayService::Responder

Inherits:
Object
  • Object
show all
Defined in:
lib/ls4/service/gw_http.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Responder

Returns a new instance of Responder.



739
740
741
742
743
744
745
 
# File 'lib/ls4/service/gw_http.rb', line 739

def initialize
  @mutex = Mutex.new
  @cond = ConditionVariable.new
  @sent = false
  @retval = nil
  @err = nil
end

Instance Attribute Details

#err ⇒ Object (readonly)

Returns the value of attribute err.



748
749
750
 
# File 'lib/ls4/service/gw_http.rb', line 748

def err
  @err
end

#retval ⇒ Object (readonly)

Returns the value of attribute retval.



747
748
749
 
# File 'lib/ls4/service/gw_http.rb', line 747

def retval
  @retval
end

Instance Method Details

#error(err, retval = nil) ⇒ Object 



774
775
776
 
# File 'lib/ls4/service/gw_http.rb', line 774

def error(err, retval = nil)
  result(retval, err)
end

#result(retval, err = nil) ⇒ Object 



762
763
764
765
766
767
768
769
770
771
772
 
# File 'lib/ls4/service/gw_http.rb', line 762

def result(retval, err=nil)
  @mutex.synchronize do
    unless @sent
      @retval = retval
      @err = err
      @sent = true
      @cond.signal
    end
  end
  nil
end

#sent? ⇒ Boolean

Returns:

  • (Boolean) 


758
759
760
 
# File 'lib/ls4/service/gw_http.rb', line 758

def sent?
  @sent
end

#wait ⇒ Object 



750
751
752
753
754
755
756
 
# File 'lib/ls4/service/gw_http.rb', line 750

def wait
  @mutex.synchronize do
    until @sent
      @cond.wait(@mutex)
    end
  end
end