Class: Bitcoin::Grpc::Receiver

Inherits:
Concurrent::Actor::Context
  • Object
show all
Includes:
Concurrent::Concern::Logging
Defined in:
lib/bitcoin/grpc/server.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(request, response, publisher, classes) ⇒ Receiver

Returns a new instance of Receiver.



199
200
201
202
203
 
# File 'lib/bitcoin/grpc/server.rb', line 199

def initialize(request, response, publisher, classes)
  @request = request
  @response = response
  classes.each {|c| publisher << [:subscribe, c] }
end

Instance Attribute Details

#request ⇒ Object (readonly)

Returns the value of attribute request.



197
198
199
 
# File 'lib/bitcoin/grpc/server.rb', line 197

def request
  @request
end

#response ⇒ Object (readonly)

Returns the value of attribute response.



197
198
199
 
# File 'lib/bitcoin/grpc/server.rb', line 197

def response
  @response
end

Instance Method Details

#on_message(message) ⇒ Object 



204
205
206
207
208
209
 
# File 'lib/bitcoin/grpc/server.rb', line 204

def on_message(message)
  if request.id == message.request_id
    log(::Logger::DEBUG, "Receiver#on_message:#{message}")
    response << message
  end
end