Class: Cosmo::Stream::Processor

Inherits:
Processor show all
Defined in:
lib/cosmo/stream/processor.rb

Constant Summary

Constants inherited from Processor

Processor::STREAMS_PAUSED_IDLE_SLEEP, Processor::STREAM_EMPTY_BACKOFF_MAX, Processor::STREAM_PAUSED_RECHECK_TTL

Instance Attribute Summary

Attributes inherited from Processor

#consumers

Method Summary

Methods inherited from Processor

#initialize, run, #run, #stop

Constructor Details

This class inherits a constructor from Cosmo::Processor