Class: RSMP::StatusCollector

Inherits:
StateCollector show all
Defined in:
lib/rsmp/collect/status_collector.rb

Overview

Base class for waiting for status updates or responses

Instance Attribute Summary

Attributes inherited from StateCollector

#matchers

Attributes inherited from Collector

#initiator, #m_id, #messages

Attributes included from Logging

#archive, #logger

Instance Method Summary collapse

Methods inherited from StateCollector

#add_command_result, #add_command_want_to_hash, #add_status_result, #add_status_want_to_hash, #build_collection, #describe, #describe_matcher, #describe_progress, #done?, #handle_match_result, #keep, #log_complete, #log_match_result, #matcher_got_hash, #matcher_result, #matcher_status, #matcher_want_hash, #messages, #perform_match?, #progress, #progress_hash, #reached, #summary

Methods inherited from Collector

#acceptable?, #active?, #build_collection, #cancel, #collect, #collect!, #complete, #crash, #describe, #done?, #fail, #incomplete, #inspect, #keep, #make_title, #perform_match?, #receive, #receive_connection_ended, #receive_event, #receive_invalid_message, #reject_not_ack?, #reset, #start, #stop, #wait, #wait!

Methods included from Logging

#author, #initialize_logging, #log

Methods included from Collector::Reporting

#describe_matcher, #describe_num_and_type, #describe_progress, #describe_types, #identifier

Methods included from Receiver

#accept_message?, #handle_message, #initialize_receiver, #inspect, #receive, #receive_event, #reject_message?, #start_receiving, #stop_receiving

Constructor Details

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

Returns a new instance of StatusCollector.



4
5
6
7
8
9
10
11
12
13
 
# File 'lib/rsmp/collect/status_collector.rb', line 4

def initialize(proxy, want, options = {})
  type = []
  type << 'StatusUpdate' unless options[:updates] == false
  type << 'StatusResponse' unless options[:reponses] == false

  super(proxy, want, options.merge(
    title: 'status response',
    filter: RSMP::Filter.new(ingoing: true, outgoing: false, type: type)
  ))
end

Instance Method Details

#build_matcher(want) ⇒ Object 



15
16
17
 
# File 'lib/rsmp/collect/status_collector.rb', line 15

def build_matcher(want)
  RSMP::StatusMatcher.new want
end

#get_items(message) ⇒ Object

Get items, in our case status values



20
21
22
 
# File 'lib/rsmp/collect/status_collector.rb', line 20

def get_items(message)
  message.attributes['sS'] || []
end