Class: RSMP::AggregatedStatusCollector

Inherits:

Collector

• Object
• Listener
• 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

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

Instance Method Summary

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

  A new instance of AggregatedStatusCollector.

Methods inherited from Collector

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

Methods inherited from Listener

#change_notifier, #listen, #notify, #notify_error

Methods included from Inspect

#inspect, #inspector

Constructor Details

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

Returns a new instance of AggregatedStatusCollector.

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

def initialize proxy, options={}
  required = { type: ['AggregatedStatus','MessageNotAck'], title: 'aggregated status' }
  super proxy, options.merge(required)
end