Class: Pixo::Rpc::Request

Inherits:
Object
  • Object
show all
Defined in:
lib/pixo/rpc/service.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(data, async) ⇒ Request

Returns a new instance of Request.



86
87
88
89
90
 
# File 'lib/pixo/rpc/service.rb', line 86

def initialize(data, async)
  @message = Pixo::Rpc::RequestMessage.new(data, async)

  @latch = Concurrent::CountDownLatch.new(1) unless async
end

Instance Attribute Details

#latch ⇒ Object (readonly)

Returns the value of attribute latch.



84
85
86
 
# File 'lib/pixo/rpc/service.rb', line 84

def latch
  @latch
end

#message ⇒ Object

Returns the value of attribute message.



81
82
83
 
# File 'lib/pixo/rpc/service.rb', line 81

def message
  @message
end

#response ⇒ Object (readonly)

Returns the value of attribute response.



83
84
85
 
# File 'lib/pixo/rpc/service.rb', line 83

def response
  @response
end

Instance Method Details

#send_result(result) ⇒ Object 



92
93
94
95
 
# File 'lib/pixo/rpc/service.rb', line 92

def send_result(result)
  @response = result
  @latch.count_down
end