Class: RSMP::AggregatedStatusCollector

Inherits:
Collector
  • Object
show all
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

#condition, #error, #m_id, #messages, #status, #task

Instance Method Summary collapse

Methods inherited from Collector

#acceptable?, #cancel, #cancelled?, #collect, #collect!, #collecting?, #complete, #describe, #describe_matcher, #describe_num_and_type, #describe_progress, #describe_types, #do_stop, #done?, #identifier, #incomplete, #ingoing?, #inspect, #keep, #log_complete, #log_incomplete, #log_start, #make_title, #ok!, #ok?, #outgoing?, #perform_match, #ready?, #receive, #receive_disconnect, #receive_error, #receive_schema_error, #reject_not_ack, #reset, #start, #timeout?, #use_task, #wait, #wait!

Methods included from Receiver

#accept_message?, #handle_message, #initialize_receiver, #receive, #receive_error, #reject_message?, #start_receiving, #stop_receiving

Methods included from Inspect

#inspect, #inspector

Constructor Details

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

Returns a new instance of AggregatedStatusCollector.



4
5
6
7
8
9
 
# 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