Class: RSMP::CommandResponseMatcher

Inherits:
Matcher show all
Defined in:
lib/rsmp/collect/message_matchers.rb

Overview

Class for waiting for specific command responses

Instance Attribute Summary

Attributes inherited from Matcher

#queries

Attributes inherited from Collector

#condition, #error, #messages, #status

Instance Method Summary collapse

Methods inherited from Matcher

#done?, #messages, #perform_match, #progress, #query_result, #query_status, #reached, #summary

Methods inherited from Collector

#cancel, #collect, #collect!, #complete, #describe_progress, #do_stop, #done?, #ingoing?, #inspect, #keep, #notify, #notify_disconnect, #notify_error, #notify_schema_error, #outgoing?, #perform_match, #reject_not_ack, #reset, #start, #type_match?, #wait, #wait!

Methods inherited from Listener

#change_notifier, #listen, #notify, #notify_error

Methods included from Inspect

#inspect, #inspector

Constructor Details

#initialize(proxy, want, options = {}) ⇒ CommandResponseMatcher

Returns a new instance of CommandResponseMatcher.



4
5
6
7
8
9
 
# File 'lib/rsmp/collect/message_matchers.rb', line 4

def initialize proxy, want, options={}
  super proxy, want, options.merge(
    type: ['CommandResponse','MessageNotAck'],
    title:'command response'
  )
end

Instance Method Details

#build_query(want) ⇒ Object 



11
12
13
 
# File 'lib/rsmp/collect/message_matchers.rb', line 11

def build_query want
  CommandQuery.new want
end

#get_items(message) ⇒ Object

Get items, in our case the return values



16
17
18
 
# File 'lib/rsmp/collect/message_matchers.rb', line 16

def get_items message
  message.attributes['rvs']
end