Class: RSMP::AggregatedStatusCollector

Inherits:

Collector

• Object
• Collector
• RSMP::AggregatedStatusCollector

Defined in:

lib/rsmp/collect/aggregated_status_collector.rb

Overview

Class for waiting for an aggregated status response

Instance Attribute Summary

Attributes inherited from Collector

#initiator, #m_id, #messages

Attributes included from Logging

#archive, #logger

Instance Method Summary

• #initialize(proxy, options = {}) ⇒ AggregatedStatusCollector constructor

  A new instance of AggregatedStatusCollector.

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, options = {}) ⇒ AggregatedStatusCollector

# File 'lib/rsmp/collect/aggregated_status_collector.rb', line 4

def initialize(proxy, options = {})
  super(proxy, options.merge(
    filter: RSMP::Filter.new(ingoing: true, outgoing: false, type: 'AggregatedStatus'),
    title: 'aggregated status'
  ))
end